SpringBoot版本:2.5.3
Zookeeper版本:3.4.9
Kafka版本:3.4.0
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。
1 zooInspector下载地址:https://issues.apache.org/jira/secure/attachment/12436620/ZooInspector.zip
2 运行build文件下 zookeeper-dev-ZooInspector.jar
3 连接信息使用默认值 Connect String:localhost:2181(zk服务地址)
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
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
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。