1.启动zookeeper

• zookeeper-server-start.bat config\zookeeper.properties

2.启动kafka

• kafka-server-start.bat config\server.properties

3.创建主题

• kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test
• 查看主题是否存在 kafka-topics.bat --list --bootstrap-server localhost:9092

4.启动生产者

• kafka-console-producer.bat --broker-list localhost:9092 --topic test

5.启动消费者

• kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning