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

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