在Windows安装运行Kafka

水深无声 2022-05-18 09:27 293阅读 0赞

转载自：[https://www.cnblogs.com/flower1990/p/7466882.html][https_www.cnblogs.com_flower1990_p_7466882.html]

## 一、安装JAVA JDK ##

1、下载安装包

[http://www.oracle.com/technetwork/java/javase/downloads/jdk8-downloads-2133151.html][http_www.oracle.com_technetwork_java_javase_downloads_jdk8-downloads-2133151.html]

注意：根据32/64位操作系统下载对应的安装包

2、添加系统变量：JAVA\_HOME=C:\\Program Files (x86)\\Java\\jdk1.8.0\_144

## 二、安装ZooKeeper ##

1、 下载安装包

http://zookeeper.apache.org/releases.html\#download

2、 解压并进入ZooKeeper目录，笔者：D:\\Kafka\\zookeeper-3.4.9\\conf

3、 将“zoo\_sample.cfg”重命名为“zoo.cfg”

4、 打开“zoo.cfg”找到并编辑dataDir=D:\\\\Kafka\\zookeeper-3.4.9\\\\tmp

5、 添加系统变量：ZOOKEEPER\_HOME=D:\\Kafka\\zookeeper-3.4.9

6、 编辑path系统变量，添加路径：%ZOOKEEPER\_HOME%\\bin

7、 在zoo.cfg文件中修改默认的Zookeeper端口（默认端口2181）

8、 打开新的cmd，输入“zkServer“，运行Zookeeper

9、 命令行提示如下：说明本地Zookeeper启动成功

[![image][]][image 1]

注意：不要关了这个窗口

## 三、安装Kafka ##

1、 下载安装包

[http://kafka.apache.org/downloads][http_kafka.apache.org_downloads]

注意要下载二进制版本

[![clip\_image003][clip_image003]][clip_image003_clip_image003]

2、 解压并进入Kafka目录，笔者：D:\\Kafka\\kafka\_2.12-0.11.0.0（**路径名称注意不要有空格，否则后面会启动报错**）

3、 进入config目录找到文件server.properties并打开

4、 找到并编辑log.dirs=D:\\Kafka\\kafka\_2.12-0.11.0.0\\kafka-logs

5、 找到并编辑zookeeper.connect=localhost:2181

6、 Kafka会按照默认，在9092端口上运行，并连接zookeeper的默认端口：2181

7、 进入Kafka安装目录D:\\Kafka\\kafka\_2.12-0.11.0.0，按下Shift+右键，选择“打开命令窗口”选项，打开命令行，输入：

.\bin\windows\kafka-server-start.bat .\config\server.properties

[![image][image 2]][image_image 2]

注意：注意：不要关了这个窗口，启用Kafka前请确保ZooKeeper实例已经准备好并开始运行

## 四、测试 ##

1、 创建主题，进入Kafka安装目录D:\\Kafka\\kafka\_2.12-0.11.0.0，按下Shift+右键，选择“打开命令窗口”选项，打开命令行，输入：

.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

[![clip\_image005][clip_image005]][clip_image005_clip_image005]

注意：不要关了这个窗口

查看主题输入：

.\bin\windows\kafka-topics.bat --list --zookeeper localhost:2181

[![clip\_image007][clip_image007]][clip_image007_clip_image007]

2、 创建生产者，进入Kafka安装目录D:\\Kafka\\kafka\_2.12-0.11.0.0，按下Shift+右键，选择“打开命令窗口”选项，打开命令行，输入：

.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test

[![image][image 3]][image_image 3]

注意：不要关了这个窗口

3、 创建消费者，进入Kafka安装目录D:\\Kafka\\kafka\_2.12-0.11.0.0，按下Shift+右键，选择“打开命令窗口”选项，打开命令行，输入：

.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning

[![image][image 4]][image_image 4]

4、 大功告成

参考网址：

[http://kafka.apache.org/][http_kafka.apache.org]

[https://github.com/confluentinc/confluent-kafka-dotnet][https_github.com_confluentinc_confluent-kafka-dotnet]

[http://www.cnblogs.com/cyfonly/p/5954614.html][http_www.cnblogs.com_cyfonly_p_5954614.html]

[http://blog.csdn.net/evankaka/article/details/52421314][http_blog.csdn.net_evankaka_article_details_52421314]

附：问题解决

***一、找不到或无法加载主类 Files\\Java\\jdk1.8.0\_31\\lib\\dt.jar;C:\\Program***

1、CLASSPATH配置有误，应该是：\*\*.;%JAVA\_HOME%\\lib\\dt.jar;%JAVA\_HOME%\\lib\\tools.jar;\*\*最前面是“小数点”不是“逗号”。

2、java环境由JRE换成JDK的话，需要修改kafka\_2.12-1.0.0\\bin\\windows\\kafka-run-class.bat文件。

具体修改内容是，将：

set COMMAND=%JAVA% %KAFKA\_HEAP\_OPTS% %KAFKA\_JVM\_PERFORMANCE\_OPTS% %KAFKA\_JMX\_OPTS% %KAFKA\_LOG4J\_OPTS% -cp **%CLASSPATH%** %KAFKA\_OPTS% %\*

改为：

set COMMAND=%JAVA% %KAFKA\_HEAP\_OPTS% %KAFKA\_JVM\_PERFORMANCE\_OPTS% %KAFKA\_JMX\_OPTS% %KAFKA\_LOG4J\_OPTS% -cp **"%CLASSPATH%"** %KAFKA\_OPTS% %\*

***二、****错误: 找不到或无法加载主类 Files\\kafka\_2.11-2.0.0\\libs\\activation-1.1.1.jar;D:\\Program***

路径中有空格， 去掉空格即不报错

[https_www.cnblogs.com_flower1990_p_7466882.html]: https://www.cnblogs.com/flower1990/p/7466882.html
[http_www.oracle.com_technetwork_java_javase_downloads_jdk8-downloads-2133151.html]: http://www.oracle.com/technetwork/java/javase/downloads/jdk8-downloads-2133151.html
[image]: /images/20220518/c0d5a9941c5541ebaeb91772504956d4.png
[image 1]: http://images2017.cnblogs.com/blog/345885/201709/345885-20170902154435062-1280345125.png
[http_kafka.apache.org_downloads]: http://kafka.apache.org/downloads
[clip_image003]: https://images2017.cnblogs.com/blog/345885/201709/345885-20170902154436405-1717631707.png
[clip_image003_clip_image003]: /images/20220518/84215d7bc8e042bc80c52daf687f95b9.png
[image 2]: https://images2017.cnblogs.com/blog/345885/201709/345885-20170902154437233-383171978.png
[image_image 2]: /images/20220518/cdd4947ce1f24acba542d3196faedf38.png
[clip_image005]: https://images2017.cnblogs.com/blog/345885/201709/345885-20170902154438155-1176522078.jpg
[clip_image005_clip_image005]: /images/20220518/18eb78e232fe4eaf884e3b30475b32ea.png
[clip_image007]: https://images2017.cnblogs.com/blog/345885/201709/345885-20170902154438983-553592507.jpg
[clip_image007_clip_image007]: /images/20220518/99361a5c5857467db8a144fde7f1ece4.png
[image 3]: https://images2017.cnblogs.com/blog/345885/201709/345885-20170902154439733-741994513.png
[image_image 3]: /images/20220518/df2050b14e9f4353808904f70ace7e3d.png
[image 4]: https://images2017.cnblogs.com/blog/345885/201709/345885-20170902154440421-564270822.png
[image_image 4]: /images/20220518/088a5c275f6845948ae36ac842446d35.png
[http_kafka.apache.org]: http://kafka.apache.org/
[https_github.com_confluentinc_confluent-kafka-dotnet]: https://github.com/confluentinc/confluent-kafka-dotnet
[http_www.cnblogs.com_cyfonly_p_5954614.html]: http://www.cnblogs.com/cyfonly/p/5954614.html
[http_blog.csdn.net_evankaka_article_details_52421314]: http://blog.csdn.net/evankaka/article/details/52421314