SpringBoot整合Kafka

环境

SpringBoot版本：2.5.3
Zookeeper版本：3.4.9
Kafka版本：3.4.0

Zookeeper安装并启动

1 zookeeper下载地址：https://archive.apache.org/dist/zookeeper/
2 选择对应版本 zookeeper-x.x.x.tar.gz 进行下载，下载完成后解压安装包。
3 进入到confg文件夹将zoo_sample.cfg的文件名修改为zoo.cfg，打开zoo.cfg文件并且修改dataDir路径。(例：D:/install/zookeeper/zk-logs)
4 在windows系统启动，进入到bin文件夹运行zkServer.cmd脚本启动zookeeper。

ZooInspector安装并启动

1 zooInspector下载地址：https://issues.apache.org/jira/secure/attachment/12436620/ZooInspector.zip
2 运行build文件下 zookeeper-dev-ZooInspector.jar
3 连接信息使用默认值 Connect String：localhost:2181（zk服务地址）

Kafka安装并启动

1 kafka下载地址：https://kafka.apache.org/downloads.html
2 选择对应版本 kafka_xxx.tgz 进行下载，下载完成后解压安装包。
3 进入config目录下，找到server.properties 编辑 log.dirs为 path+\logs (例：D:/install/kafka/kafka-logs)
4 在windows系统常用操作如下：
启动 .\bin\windows\kafka-server-start.bat .\config\server.properties
创建Topic .\bin\windows\kafka-topics.bat --bootstrap-server localhost:9092 --create --replication-factor 1 --partitions 1 --topic test-topic
查看Topic列表 .\bin\windows\kafka-topics.bat --bootstrap-server localhost:9092 --list
查看Topic详情 .\bin\windows\kafka-topics.bat --bootstrap-server localhost:9092 --describe --topic test-topic
删除Topic .\bin\windows\kafka-topics.bat --bootstrap-server localhost:9092 --delete --topic test-topic
创建生产者 .\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test-topic
创建消费者 .\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test-topic --from-beginning
创建消费者组 .\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test-topic --from-beginning --group test-group
查看消费者组 .\bin\windows\kafka-consumer-groups.bat --bootstrap-server localhost:9092 --list
查看消费者组详情 .\bin\windows\kafka-consumer-groups.bat --bootstrap-server localhost:9092 --describe --group test-group

Kafka Tools安装并启动

1 Kafka Tools下载地址：https://www.kafkatool.com/download.html
2 直接点击exe文件，一键安装即可。
3 使用默认值连接即可。

注意

在windows系统删除Topic导致的问题解决：
1 停止zookeeper服务，删除zookeeper整个log文件夹。
2 删除kafka整个log文件夹。
3 重启zookeeper，重启kafka。
参考：https://www.cnblogs.com/duanguyuan/p/14973003.html