1.进入kafka中bin目录下的windows目录
2.启动zookeeper
zookeeper-server-start.bat ..\..\config\zookeeper.properties
查看启动成功端口监听 netstat -ano|findstr 2181
3.启动kafka
kafka-server-start.bat ..\..\config\server.properties
查看启动成功端口监听 netstat -ano|findstr 9092
4.创建topic
kafka-topics.bat --create --topic test --replication-factor 1 --partitions 1 --zookeeper localhost:2181
--topic 指定topic名字
--replication-factor 指定副本数
--partitions 指定分区数，这个参数需要根据broker数和数据量决定
查看创建的topic
kafka-topics.bat --describe --topic test --zookeeper localhost:2181
查看所有的topic
kafka-topics.bat --list --zookeeper localhost:2181
5.发送消息到topic
5.1无key型消息
kafka-console-producer.bat --bootstrap-server localhost:9092 --topic test
5.2有key型消息
kafka-console-producer.bat --bootstrap-server localhost:9092 --topic test --property parse.key=true
默认消息键与消息值间使用“Tab