上节搭建了zookeeper与kafka环境,这一节要测试环境是否能正常工作。
1,紧接着上节的内容,zookeeper与kafka都启动好了,新开一个命令窗口,定为到
D:softkafka_2.11-0.9.0.0inwindows
2,创建topic
输入命令 .kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test 来创建topic 名为test。topic可以理解为一个逻辑队列,逻辑队列里存放消息的是若干个(可配置)partitions。
3,创建一个生产者和一个消费者来测试消息
打开两个命令窗口, 定为到D:softkafka_2.11-0.9.0.0inwindows,一个用于producer,另一个作为consumer
a)创建producer
kafka-console-producer.bat --broker-list localhost:9092 --topic test
b)创建consumer
kafka-console-consumer.bat --zookeeper localhost:2181 --topic test
得到两个命令窗口如下:
如果成功了 在producer窗口输入内容可以在consumer窗口打印出来,如下: