kafka测试实用命令

1、创建主题

./kafka-topics.sh --create --zookeeper zk1:2181,zk2:2181,zk3:2181 --replication-factor 1 --partitions 1 --topic streams-plaintext-input

2、查看主题

./kafka-topics.sh --describe --zookeeper zk1:2181,zk2:2181,zk3:2181  --topic streams-plaintext-input

3、删除主题

./kafka-topics.sh --delete  --zookeeper zk1:2181,zk2:2181,zk3:2181 --topic spark_streaming_kafka_default_topic

4、发送消息

./kafka-console-producer.sh --broker-list zk1:9092,zk2:9092,zk3:9092 --topic streams-plaintext-input

5、消费消息

./kafka-console-consumer.sh --bootstrap-server zk1:9092,zk2:9092,zk3:9092 --from-beginning  --topic streams-pipe-output

具体参数不明白 ，--help  

参考：https://www.cnblogs.com/cjsblog/p/9409443.html