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

  • 相关阅读:
    HDOJ 1284 钱币兑换问题
    WA : csu1019 simple line editor
    HDOJ1232 并查集
    最长回文子串
    Where's Waldorf?
    csu 1148 词典
    csu 1011 Counting Pixels
    Product:java高精度乘法
    内置类型开方
    csu 1019 Simple Line Editor
  • 原文地址:https://www.cnblogs.com/heml/p/6073880.html
Copyright © 2011-2022 走看看