kafka测试实用命令

Posted 2020-11-13 mylittlecabin

1、创建主题

 

./kafka-topics.sh --create --zookeeper vm1:2181,vm2:2181,vm3:2181 --replication-factor 1 --partitions 1 --topic streams-plaintext-input

 

2、查看主题

 

./kafka-topics.sh --describe --zookeeper vm1:2181,vm2:2181,vm3:2181  --topic streams-plaintext-input

 

3、发送消息

 

./kafka-console-producer.sh --broker-list vm1:9092,vm2:9092,vm3:9092 --topic streams-plaintext-input

 

4、消费消息

 

./kafka-console-consumer.sh --bootstrap-server vm1:9092,vm2:9092,vm3:9092 --from-beginning  --topic streams-pipe-output

 

具体参数不明白 ，--help  

 

 

 

 

 

 

 

 

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