1. 程式人生 > >kafka shell 命令列操作

kafka shell 命令列操作

kafka的命令列操作
    1、產看當前叢集中已存在的主題topic
        bin/kafka-topics.sh --list --zookeeper bigdata:2181 
    2、建立主題topic
        bin/kafka-topics.sh --create --zookeeper bigdata:2181 --replication-factor 1 --partitions 1 --topic test1
            --zookeeper 連線zk叢集
            --create 建立
            --replication-factor    副本
            --partitions    分割槽
            --topic     主題名
    3、刪除主題
        bin/kafka-topics.sh --delete --zookeeper bigdata:2181 --topic test1
    4、傳送訊息(producer)
        bin/kafka-console-producer.sh --broker-list bigdata:9092 --topic test
    5、接收訊息(consumer)
        老版本
            bin/kafka-console-consumer.sh --zookeeper bigdata:2181 --topic test --from-beginning
        新版本啟動方式:
            bin/kafka-console-consumer.sh --bootstrap-server bigdata:9092 --topic test --from-beginning
    6、檢視主題詳細資訊
        bin/kafka-topics.sh --zookeeper bigdata:2181 --describe --topic test
            Topic:test1    PartitionCount:1    ReplicationFactor:1    Configs:
                Topic: test1    Partition: 0    Leader: 0    Replicas: 0    Isr: 0