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