windows 环境下安装 Kafka
一、安装JDK
因本地基本上都已安装好JDK,所以此步略过,直接打开cmd,键入 "java -version"命令查看当前系统的 Java 版本。
二、安装ZooKeeper
-
下载安装包。
下载地址:http://zookeeper.apache.org/releases.html#download
作者下载的是:apache-zookeeper-3.5.7-bin.tar.gz
高版本的zookeeper,一般会有2个不同的包,如:apache-zookeeper-3.6.0.tar.gz 和 apache-zookeeper-3.6.0-bin.tar.gz,使用带 bin 的二进制版本,否则在启动 zookeeper 时可能会报 “找不到或无法加载主类 org.apache.zookeeper.server.quorum.QuorumPeerMain” 错误。 -
解压并进入 ZooKeeper 的 conf 目录,将 zoo_sample.cfg 重命名为 zoo.cfg。
作者的目录:D:\Program Files\apache-zookeeper-3.5.7-bin\apache-zookeeper-3.5.7-bin\conf -
打开 zoo.cfg 文件,做如下修改。
修改:dataDir=D:\Program Files\apache-zookeeper-3.5.7-bin\apache-zookeeper-3.5.7-bin\data
添加:dataLogDir=D:\Program Files\apache-zookeeper-3.5.7-bin\apache-zookeeper-3.5.7-bin\logs
添加:admin.serverPort=8888(PS:因在后续启动时报 8080 端口占用,所以修改端口为8888) -
添加系统变量
ZOOKEEPER_HOME=D:\Program Files\apache-zookeeper-3.5.7-bin\apache-zookeeper-3.5.7-bin -
编辑 path 系统变量,在其后添加 “;%ZOOKEEPER_HOME%\bin;”
-
打开 cmd,输入 “zkServer”,运行 Zookeeper,命令行提示如下图所示,则说明本地 Zookeeper 启动成功。
cmd 窗口不要关闭,继续安装 kafka。
三、安装并运行 kafka
- 下载安装文件: http://kafka.apache.org/downloads.html,作者下载的是 kafka_2.11-2.4.0.tgz。
- 将文件解压到 D 盘根路径。
- 进入 D:\kafka_2.11-2.4.0\config 目录,文本编辑器打开 server.properties,修改 log.dirs=D:\kafka_2.11-2.4.0\logs
- 进入 D:\kafka_2.11-2.4.0 目录,shift + 右键,在此处打开命令窗口,输入如下命令
.\bin\windows\kafka-server-start.bat .\config\server.properties
回车后出现
[2020-04-09 16:55:29,122] INFO [KafkaServer id=0] started (kafka.server.KafkaServer)
则说明启动完毕。
PS:在键入上述命令时,作者出现过如下所示的错误。
起初安装路径较深,后改为了D盘根路径后错误解决。
窗口不要关闭,进入测试环节。
四、测试 kafka
- 创建 topic。
在 D:\kafka_2.11-2.4.0\bin\windows 路径下打开 cmd 窗口,创建一个主题 test,命令如下:
kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
结果如下图所示:
- 打开一个 PRODUCER。
在 D:\kafka_2.11-2.4.0\bin\windows 路径下打开 cmd 窗口,键入如下命令:
kafka-console-producer.bat --broker-list localhost:9092 --topic test
- 打开一个 CONSUMER。
在 D:\kafka_2.11-2.4.0\bin\windows 路径下打开 cmd 窗口,键入如下命令:
kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning
- 在 Producer 控制台窗口输入消息,在消息输入过后,很快 Consumer 窗口就会显示出 Producer 发送的消息,如下图所示。
至此,Kafka 运行环境的搭建就完成了。
推荐阅读
-
windows 环境下安装 Kafka
-
在windows下搭建Kafka环境
-
ubuntu18.04下Kafka安装与部署
-
Ubuntu下安装Kafka
-
在 Windows 10 64 下安装 Memcached和安装 PHP 7.0.22 的 Memcache 扩展
-
mac环境下安装mamp,PHP文件不能解析。
-
在windows下安装gulp -- 基于 Gulp 的前端集成解决方案(一)_html/css_WEB-ITnose
-
Windows XP系统下安装apache+php+mysql_PHP
-
mysql (1) : WINDOWS下安装mysql
-
基于Windows环境下的PHP开发环境搭建