windows 安装 kalfka 并快速启动

1.安装Java 环境

https://www.java.com/zh_CN/

直接下载安装即可

(如果之前有配置过java环境 可以先跳过此步骤，但是如果运行的时候报错就需要把之前的jdk环境变量删除 重新安装下载的jre8

亲测只有jre8 的环境可以,如果有更合适的建议请留言谢谢！)

2.下载安装kalfka

地址   https://archive.apache.org/dist/kafka/0.11.0.3/kafka_2.12-0.11.0.3.tgz

（或者到官网下载其他版本  http://kafka.apache.org/downloads）

下载完成后直接解压到本地的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.3binwindowszookeeper-server-start.bat D:kafka_2.12-0.11.0.3configzookeeper.properties "

start cmd /k "ping 127.1 -n "4">nul&&D:kafka_2.12-0.11.0.3binwindowskafka-server-start.bat D:kafka_2.12-0.11.0.3configserver.properties"

#（第一次先需要创建一个 topic）

start cmd /c "D:kafka_2.12-0.11.0.3binwindowskafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 2 --topic [TOPICNAME]"

#（启动cconsumer）

start cmd /k "D:kafka_2.12-0.11.0.3binwindowskafka-console-consumer.bat --bootstrap-server localhost:9092 --topic [TOPICNAME] --from-beginning"

最后将文件扩展名修改为.bat  

5.完成并使用

　　使用的时候点击创建的.bat 快捷工具即可运行

 

 

 

参考：https://www.cnblogs.com/nhz-M/p/10048055.html