启动生产者
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
输入完了之后就卡着了… 等待生产者生产数据.
参考: