小付博客

windows10下Kafka 运行测试

发布时间：2018-09-19 编辑：小付 浏览（1532） 评论（0）

上篇文章讲述了在win10环境下安装kafka环境，本章接上篇继续讲述 kafka在命令行中进行测试




步骤1：


运行Zookeeper




步骤2：

运行Kafka




前两个步骤见上篇：http://fubb.me/article/view/289.html




步骤3：创建topics

打开cmd 并进入G:\kafka_2.11-0.10.0.1\bin\windows

创建一个topic：

kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --parti
tions 1 --topic test0811

创建完成后 可以关闭cmd窗口了




步骤4：打开一个生产者窗口(Producer)

PS D:\kafka\kafka\kafka_2.10-0.9.0.1\bin\windows> .\kafka-console-producer.bat --broker-list 
localhost:9092 --topic test0811

执行完命令后 不要关闭窗口




步骤5：打开一个消费者者窗口(consumer)

PS D:\kafka\kafka\kafka_2.10-0.9.0.1\bin\windows> .\kafka-console-consumer.bat --zookeeper 
localhost:2181 --topic test0811

同样执行完命令后 不要关闭窗口




步骤6：回到刚才未关闭的Producer 窗口(步骤4) 

然后就可以在Producer控制台窗口输入消息了。在消息输入过后，很快Consumer窗口就会显示出Producer发送的消息






至此测试完成