安装路径:D:\kafka\kafka_2.13-3.2.0\
启动zookeeper
D:\kafka\kafka_2.13-3.2.0>.\bin\windows\zookeeper-server-start.bat .\config\zookeeper.properties
启动kafka
D:\kafka\kafka_2.13-3.2.0>.\bin\windows\kafka-server-start.bat .\config\server.properties
查看topic列表
D:\kafka\kafka_2.13-3.2.0\bin\windows> kafka-topics.bat --list --bootstrap-server localhost:9092
创建topic
D:\kafka\kafka_2.13-3.2.0\bin\windows>kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic ceshiTopic
删除topic
kafka-topics.bat --delete --bootstrap-server localhost:9092 --topic ceshiTopic
生产消息
D:\kafka\kafka_2.13-3.2.0\bin\windows> kafka-console-producer.bat --broker-list localhost:9092 --topic datasync
消费消息
D:\kafka\kafka_2.13-3.2.0\bin\windows> kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic datasync --from-beginning
–from-beginning 表示消费该主题的所有消息;没有则表示只消费创建后该主题发布的消息
查看kafka指定TOPIC的详情
kafka-topics.bat --bootstrap-server localhost:9092 --topic datasync --describe
查看消费组列表
D:\kafka\kafka_2.13-3.2.0\bin\windows>kafka-consumer-groups.bat --bootstrap-server 127.0.0.1:9092 --list
查看消费组详情
kafka-consumer-groups.bat -bootstrap-server 127.0.0.1:9092 --group g_k --describe
查看指定消费组消费情况查看
kafka-consumer-groups.bat --describe --bootstrap-server 127.0.0.1:9092 --group g_k
查看所有消费组消费情况
kafka-consumer-groups.bat --describe --bootstrap-server 127.0.0.1:9092 --all-groups