Kafka 学习笔记之 Kafka0.11之console-producer/console-consumer


Kafka 学习笔记之 Kafka0.11之console-producer/console-consumer:

 

启动Zookeeper

启动Kafka0.11

创建一个新的Topic:

 ./kafka-topics.sh --create --zookeeper hadoop1:2181,hadoop2:2181,hadoop3:2181 --replication-factor 1 --partitions 3 --topic Topic011

查询Topic列表:

./kafka-topics.sh --list --zookeeper hadoop1:2181,hadoop2:2181,hadoop3:2181

查看Topic详细信息:

./kafka-topics.sh --describe --zookeeper hadoop1:2181,hadoop2:2181,hadoop3:2181 --topic Topic011

建立订阅者console-consumer:Note:在0.9版本指定的是zookeeper server,0.11变成了broker server

./kafka-console-consumer.sh --bootstrap-server hadoop1:9092,hadoop2:9092,hadoop3:9092 --topic Topic011

建立发布者console-producer:

./kafka-console-producer.sh --broker-list hadoop1:9092,hadoop2:9092,hadoop3:9092 --topic Topic011

 

发送消息:

 


免责声明!

本站转载的文章为个人学习借鉴使用,本站对版权不负任何法律责任。如果侵犯了您的隐私权益,请联系本站邮箱yoyou2525@163.com删除。



 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM