您的位置:首页 > 其它

kafka客户端自带的脚本生产-消费消息

2018-02-20 21:44 771 查看

使用控制台脚本生产-消费消息

使用控制台的生产者脚本生产消息

➜  bin sh kafka-console-producer.sh --broker-list localhost:9092 --topic test
>one
>two
>three


使用控制台的消费者脚本消费消息

➜  bin sh kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
one
two
three


管理consumer分区

列出所有的consumer

sh kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list


查询所有的topic

sh kafka-topics.sh  --list --zookeeper 192.168.10.151:2181


参考文档

http://kafka.apache.org/documentation/#basic_ops_add_topic
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签:  kafka 控制台脚本