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

     在生產消息的窗口輸入內容，消費窗口就可以打印出來：