【kafka连载二】windows测试kafka的消息收发

前提

系统已启动zookeeper和kafka服务，若没有启动请执行以下操作

启动zookeeper

CMD窗口进入zookeeper的bin子目录执行.\zkServer.cmd

启动kafka

CMD窗口进入进入kafka目录并执行.\bin\windows\kafka-server-start.bat .\config\server.properties

创建生产者producer

CMD窗口进入kafka\bin\window子目录，并执行.\kafka-console-producer.bat --broker-list localhost:9092 --topic testtopic(已创建的topic名称)  不用关闭窗口！！！！

创建消费者consumer

CMD窗口进入kafka\bin\window子目录，并执行.\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test0909 --from-beginning(可以不添加，加了就读取已存储的消息) 不用关闭窗口！！！！

发布消息和接收消息

在创建者窗口输入任意字符

在消费者窗口查收消息