1.安装Java 环境
https://www.java.com/zh_CN/
直接下载安装即可
(如果之前有配置过java环境 可以先跳过此步骤,但是如果运行的时候报错就需要把之前的jdk环境变量删除 重新安装下载的jre8
亲测只有jre8 的环境可以,如果有更合适的建议请留言谢谢!)
2.下载安装kalfka
地址
(或者到官网下载其他版本 )
下载完成后直接解压到本地的D盘文件夹(建放在空间大点的非系统盘,后期会产生log日志)
3.修改log日志的存储地址
用代码编辑工具打开config/server.properties文件(用记事本打开看不出换行和注释容易修改错误):
(地址也可以自己定义)
log.dirs=D:\\kafka_2.12-0.11.0.3\\kafka_log
listeners=PLAINTEXT://localhost:9092 #这里是为了研究kafka的topic删除时 “标记删除”为false ,删除为true delete.topic.enable=true
同样打开config/zookeeper.properties :
dataDir=D:\\kafka_2.12-0.11.0.3\\zkdata
4.创建快速启动工具
在自己使用方便的路径下新建一个记事本复制上以下内容:
(根据自己下载的kalfka版本的文件夹名称修改路径)
#删除log文件 如果有之前的log有时候后kalfka启动会有问题
rd/s/q D:\\
kafka_2.12-0.11.0.3
\\kafka_log
start cmd /k "D:\kafka_2.12-0.11.0.3\bin\windows\zookeeper-server-start.bat D:\kafka_2.12-0.11.0.3\config\zookeeper.properties "
start cmd /k "ping 127.1 -n "4">nul&&D:\kafka_2.12-0.11.0.3\bin\windows\kafka-server-start.bat D:\kafka_2.12-0.11.0.3\config\server.properties"
#(第一次先需要创建一个 topic)
start cmd /c "D:\kafka_2.12-0.11.0.3\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 2 --topic [TOPICNAME]"
#(启动cconsumer)
start cmd /k "D:\kafka_2.12-0.11.0.3\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic [TOPICNAME] --from-beginning"
最后将文件扩展名修改为.bat
5.完成并使用
使用的时候点击创建的.bat 快捷工具即可运行
参考:https://www.cnblogs.com/nhz-M/p/10048055.html