启动生产者

kafka提供了用于测试的producer,位置在kafka_2.11-0.11.0.2/bin目录下面,有个kafka-console-producer.sh

命令

kafka-console-producer.sh --broker-list zjj101:9092  --topic hello

启动消费者

kafka_2.11-0.11.0.2/bin目录下面,有个kafka-console-consumer.sh 将生产者的数据打印在控制台上面

命令 :

kafka-console-consumer.sh --bootstrap-server zjj101:9092 --topic hello

输入完了之后就卡着了… 等待生产者生产数据.

参考:

​