赞
踩
我这里安装的是jdk1.8
需要进行安装配置,具体的安装教程可以参考
方式一:公众号获取
关注 I am Walker
回复zookeeper
方式二:官网下载:
https://zookeeper.apache.org/releases.html
这里下载编译好的
下载后进行解压
将conf/zoo_sample.cfg修改为zoo.cfg
查询dataDir 然后创建一个新的data文件夹,并将路径修改为它
记得以\\
进行分割
添加系统变量 ZOOKEEPER_HOME,值为自己下载的zookeeper的路径,如我的 D:\env\apache-zookeeper-3.7.1-bin\apache-zookeeper-3.7.1-bin\conf
编辑path变量,添加%ZOOKEEPER_HOME%\bin
打开命令行,执行zkServer
该窗口不要关闭
方式一:关注I am Walker
回复 kafka
方式二:官网下载
https://kafka.apache.org/downloads
解压后将文件夹名称改为kafka,名称不能太长,否则后面启动的时候会出现错误
查询log.dirs,修改日志路径,可以自己创建一个logs文件夹
log.dirs=D:\env\kafka\kafka\logs
如果zookeeper的ip和端口没做改变,则不需要修改
.\bin\windows\kafka-server-start.bat .\config\server.properties
启动前确认zookeeper是开启的
之后该命令行不要关闭
#
.\bin\windows\kafka-topics.bat
--create
--zookeeper localhost:2181
--replication-factor 1
--partitions 1
--topic test
.\bin\windows\kafka-topics.bat --list --zookeeper localhost:2181
.\bin\windows\kafka-console-producer.bat
--broker-list localhost:9092
--topic test
.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning
在生产者中输入“hello”,可以发现在消费者中能接受到"hello"
.\bin\windows\kafka-topics.bat --delete --zookeeper localhost:2181 --topic test
可以发现是逻辑删除,并不是先直接物理删除的
删除后重新查询列表
.\bin\windows\kafka-topics.bat --list --zookeeper localhost:2181
解决办法:
1.去kafka日志目录下删除log里topic日志(重启kafka还是报错)。
2. 还需要删除zookeeper里zoo.cfg里配置的dataDir目录下的日志。
方式一:
文件名称太长,将其直接改为kafka
方式二:
https://blog.csdn.net/FunnyWhiteCat/article/details/126241088
方式一:
关注I am Walker
回复 offset Explorer
方式二:官网下载
https://www.kafkatool.com/download.html
打开之后按着步骤安装即可
安装成功,使用该工具打开
打开之后连接即可
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。