1、创建Topic
kafka-topics.sh --create --topic test --partitions 2 --replication-factor 2 --zookeeper node01:2181
--create：指定要执行的动作。此处为创建
--topic：指定topic名称
--partitions：指定分区数量
--replication-factor：指定副本数量
--zookeeper：指定ZK集群地址
2、列出所有topic
kafka-topics.sh --list --zookeeper node01:2181
--list：指定要执行的动作。此处为列出所有topic
--zookeeper：自定ZK集群地址
3、查看某个topic的详细信息
kafka-topics.sh --describe --topic test --zookeeper node01:2181
--describe：指定要执行的动作。此处为topic详细信息
--topic：指定topic名称
--zookeeper：指定ZK集群地址
4、测试生产者生产数据
kafka-console-producer.sh --broker-list node01:9092,node02:9092,node03:9092 --topic test
--broker-list：指定Kafka集群地址
--topic：指定要生产数据的topic
5、测试消费者消费数据
kafka-console-consumer.sh --bootstrap-server node01:9092,node02:9092,node03:9092 --topic test
--bootstarp-server：指定Kafka集群地址
--topic：指定要消费数据的topic
