Windos 安装配置 Kafka

安装步骤

步骤一:安装JDK环境

按照这个教程安装设置: https://www.cnblogs.com/IT-Ramon/p/12017387.html

步骤二:下载Zookeeper

下载地址:https://archive.apache.org/dist/zookeeper/zookeeper-3.4.13/zookeeper-3.4.13.tar.gz

步骤三:下载Kafka

下载地址:http://kafka.apache.org/downloads

一、配置Zookeeper

1、解压并进入ZooKeeper目录,小编:C:Kafkazookeeper-3.4.13conf

2、 将“zoo_sample.cfg”重命名为“zoo.cfg”

3、 打开“zoo.cfg”找到并编辑dataDir=C:\Kafka\zookeeper-3.4.13\tmp

4、添加系统变量:ZOOKEEPER_HOME=C:\Kafka\zookeeper-3.4.13(这个好像加不加都行)

5、 编辑path系统变量,添加路径:%ZOOKEEPER_HOME%in

6、在zoo.cfg文件中修改默认的Zookeeper端口(默认端口2181)

7、在C:Kafkazookeeper-3.4.13in目录下打开新的cmd,输入"zkServer",运行Zookeeper

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

 注意:不要关了这个窗口

 二、配置Kafka

1、解压并进入Kafka目录,小编:C:Kafkakafka_2.12-2.3.1

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

3、找到并编辑log.dirs=C:Kafkakafka_2.12-2.3.1kafka-logs

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

5、Kafka会按照默认,在9092端口上运行,并链接zookeeper的默认端口:2181

6、进入Kafka安装目录C:Kafkakafka_2.12-2.3.1,打开cmd执行以下命令:

.inwindowskafka-server-start.bat .configserver.properties

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

三、测试

1、创建主题,进入Kafka安装目录C:Kafkakafka_2.12-2.3.1,打开cmd执行以下命令:

.inwindowskafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

注意:不要关了这个窗口

查看主题输入:

.inwindowskafka-topics.bat --list --zookeeper localhost:2181

 2、创建生产者,进入Kafka安装目录C:Kafkakafka_2.12-2.3.1,打开cmd执行以下命令:

.inwindowskafka-console-producer.bat --broker-list localhost:9092 --topic test

注意:不要关了这个窗口

3、创建消费者,进入Kafka安装目录C:Kafkakafka_2.12-2.3.1,打开cmd执行以下命令:

.inwindowskafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning

 当你看到 “hello” 、 “hi” 字样就大功告成了,说明消费者收到了生产者发出的信息

原文地址:https://www.cnblogs.com/IT-Ramon/p/12017745.html