码迷,mamicode.com
首页 > 其他好文 > 详细

kafka测试实用命令

时间:2019-09-10 23:40:09      阅读:90      评论:0      收藏:0      [点我收藏+]

标签:keep   发送   list   ref   put   pre   out   output   ica   

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

kafka测试实用命令

标签:keep   发送   list   ref   put   pre   out   output   ica   

原文地址:https://www.cnblogs.com/mylittlecabin/p/11503676.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!