windows 安装 kalfka 并快速启动

1.下载

地址 https://www.apache.org/dyn/closer.cgi?path=/kafka/2.3.0/kafka-2.3.0-src.tgz

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

2.安装

下载完成后直接解压到本地的D盘文件夹（建放在空间大点的非系统盘，后期会产生log日志）

3.修改log日志的存储地址

用代码编辑工具打开config/server.properties文件（用记事本打开看不出换行和注释容易修改错误）：

（地址也可以自己定义）

  log.dirs=D:\\kafka_2.3.0\\kafka_log

　listeners=PLAINTEXT://localhost:9092

  #这里是为了研究kafka的topic删除时  “标记删除”为false ,删除为true

  delete.topic.enable=true

同样打开config/zookeeper.properties ：

dataDir=D:\\kafka_2.3.0\\zkdata

4.创建快速启动工具

在自己使用方便的路径下新建一个记事本复制上以下内容：

(根据自己下载的kalfka版本的文件夹名称修改路径)

 1     start cmd /k "D:\kafka_2.3.0\bin\windows\zookeeper-server-start.bat D:\kafka_2.3.0\config\zookeeper.properties "
 2 
 3     start cmd /k "ping 127.1 -n "4">nul&&D:\kafka_2.3.0\bin\windows\kafka-server-start.bat D:\kafka_2.3.0\config\server.properties"
 4 
 5     #（第一次先需要创建一个  topic）
 6     start cmd /c "D:\kafka_2.3.0\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 2 --topic [TOPICNAME]
 7 
 8     #（启动cconsumer）
 9 
10     kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic  [TOPICNAME] --from-beginning

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

5.完成并使用

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

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

windows 安装 kalfka 并快速启动

猜你喜欢