1、创建topic

使用shell新开一个node001的窗口

命令建议手敲（不仅仅是为了练习代码，重要的是：我复制命令粘贴上去有时候要报错，手敲却没问题，不知道为啥）

终端输入：

kafka-topics.sh --bootstrap-server node3:9092 --create --topic topic-test --partitions 2 --replication-factor 1

解释：
--replication-factor 1 #复制两份
--partitions 2 #创建1个分区
--topic #主题为topic-test

2、查看topic

查看所有的topic

kafka-topics.sh --bootstrap-server node3:9092 --list

3、查看某一个topic

kafka-topics.sh --describe --bootstrap-server node3:9092 --topic topic-test

4、删除topic

# 删除aa这个topic
kafka-topics.sh --bootstrap-server node3:2181 --delete --topic aa   

5、启动控制台生产者

kafka-console-producer.sh --broker-list node3:9092 --topic topic-test

6、启动控制台消费者

使用shell再开一个node4的窗口

kafka-console-consumer.sh --bootstrap-server node3:9092 --topic topic-test --from-beginning

参考连接：https://blog.csdn.net/wudidahuanggua/article/details/127086186