kafka生产者与消费者命令测试


     接上一篇kafka环境搭建完成后,进入测试阶段,首先试一下最基本的生产与消费者。

     1、创建topic,使用 kafka-topics.sh 创建 topic test

       bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

     2、创建消息生产者

      

     看一下zookeeper 配置信息: bin/zookeeper-shell.sh localhost:2181 <<< "get /brokers/ids/0"

       

     创建时生产者的时候我们用的是**localhost,**这里我们改成:bin/kafka-console-producer.sh --broker-list PLAINTEXT://上面的ip:9092 --topic test

     3、创建消息消费者;bin/kafka-console-consumer.sh --bootstrap-server PLAINTEXT://上面的ip:9092 --topic test --from-beginning

     在生产消息的窗口输入内容,消费窗口就可以打印出来: 

      

 


免责声明!

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



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