kafka常用命令

轉自：https://blog.csdn.net/learn_tech/article/details/84670795

1、生產者操作：

kafka-console-producer.sh --broker-list node1:9092 --topic my-kafka-topic //my-kafka-topic時topic的名字

2、消費者操作：

通過命令，可以看到消費者可以接收生產者發送的消息 

kafka-console-consumer.sh --bootstrap-server node1:9092 --topic my-kafka-topic

 3、如果需要從頭開始接收數據，需要添加--from-beginning參數

kafka-console-consumer.sh --bootstrap-server node01:9092 --from-beginning --topic my-kafka-topic

4、創建topic

kafka-topics.sh --create --zookeeper node1:2181 --replication-factor 1 --partitions 1 --topic my-kafka-topic

5、查看topic列表

kafka-topics.sh --list --zookeeper node01:2181

6、如果需要查看topic的詳細信息，需要使用describe命令

kafka-topics.sh --describe --zookeeper node1:2181 --topic test-topic

7、若不指定topic，則查看所有topic的信息

kafka-topics.sh --describe --zookeeper node1:2181

8、刪除topic

kafka-topics.sh --delete --zookeeper node1:2181 --topic my-kafka-topic