安装Kafka
打开CMD 到C:\Develop\kafka_2.11-0.9.0.0这个路径下,输入
bin\windows\kafka-server-start.bat config\server.properties
——启动Kafka,可以创建主题来存储消息
创建主题
打开CMD 到C:\Develop\kafka_2.11-0.9.0.0\bin\windows输入
kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test1
创建Producer及Consumer来测试服务器
输入
kafka-console-producer.bat --broker-list localhost:9092 --topic test1
再打开一个cmd,输入
kafka-console-consumer.bat --zookeeper localhost:2181 --topic test1
在producer命令行中任意输入内容,回车;在其他consumer命令行中能看到相应消息