zoukankan      html  css  js  c++  java
  • kafka 命令行操作

    1、创建topic

    bin/kafka-topics.sh --create --zookeeper m1:2181 --replication-factor 1 --partitions 1 --topic test

    --create 执行创建指令
    --zookeeper 指定连接zookeeper的地址
    --replication-factor 副本因子
    --partitions 分区数
    --topic test topic的名称

    2、查看topic

    bin/kafka-topics.sh --list --zookeeper m1:2181

    3、向topic发送消息

     bin/kafka-console-producer.sh --broker-list m1:9092 --topic test

    --broker-list 指定broker的地址
    --topic 指定topic名称

    4、 消费消息

     bin/kafka-console-consumer.sh --bootstrap-server m1:9092 --topic test --from-beginning

    --bootstrap-server broker的地址
    --topic 指定topic名称
    --from-beginning 从头消费消息

    5、查看topic信息

    查看topic相信信息

    创建多个副本的topic

    bin/kafka-topics.sh --create --zookeeper m1:2181 --replication-factor 2 --partitions 2 --topic test2
    bin/kafka-topics.sh --describe --zookeeper m1:2181 --topic test2

    Topic: topic名称
    PartitionCount: 分区总数
    ReplicationFactor: 副本因子
    Configs: 消息相关配置信息
    Topic: topic名称    Partition: 分区标号,从0开始 Leader: 分区leader所在的broker id         Replicas: 副本所在的 broker id      Isr: 还存活的broker id

  • 相关阅读:
    8u ftp 可以连接但是无法获取目录的解决办法:无法打开传输通道。原因:由于...
    自学Oracle心得
    Java程序员到架构师的推荐阅读书籍
    (转)Java中Image的水平翻转、缩放与自由旋转操作
    IOC和DI
    Spring简介
    正则表达式
    反射
    网络编程
    GUI( 图形用户界面)
  • 原文地址:https://www.cnblogs.com/heml/p/6073880.html
Copyright © 2011-2022 走看看