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.3inwindowszookeeper-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.3inwindowskafka-server-start.bat D:kafka_2.12-0.11.0.3configserver.properties"

#(第一次先需要创建一个 topic)

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

#(启动cconsumer)

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

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

5.完成并使用

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

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

原文地址:https://www.cnblogs.com/ITCoNan/p/11254663.html