轉自：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