上节搭建了zookeeper与kafka环境，这一节要测试环境是否能正常工作。
1，紧接着上节的内容，zookeeper与kafka都启动好了，新开一个命令窗口，定为到
D:\soft\kafka_2.11-0.9.0.0\bin\windows
2，创建topic
输入命令 .\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test 来创建topic 名为test。topic可以理解为一个逻辑队列，逻辑队列里存放消息的是若干个（可配置）partitions。
3，创建一个生产者和一个消费者来测试消息
打开两个命令窗口， 定为到D:\soft\kafka_2.11-0.9.0.0\bin\windows，一个用于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窗口打印出来，如下：
kafka zookeeper学习（2） 测试kafka与zookeeper环境
原文：http://www.cnblogs.com/Forrest-Janny/p/6953073.html