kafka的安装及运行

kafka的安装及运行

kafka的安装运行需要共三条件：

1、JDK安装环境

2、安装ZooKeeper

3、安装Kafka

一、JDK安装环境

略。。。。。。。。。

二、安装ZooKeeper

1、下载安装包：

链接：https://pan.baidu.com/s/1Owh_rOEg48X1cDJV-jU6AQ 
提取码：az9c

2、解压安装包并进入安装目录，D:zookeeperapache-zookeeper-3.6.3-bin

3、复制"zoo_sample.cfg"文件并重命名为"zoo.cfg"

4、用记事本打开"zoo.cfg"文件，找到"dataDir"变量，修改为本地安装路径（dataDir=D:zookeeperapache-zookeeper-3.6.3-bin）

5、配置系统环境变量，新增环境变量（ZOOKEEPER_HOME = D:zookeeperapache-zookeeper-3.6.3-bin）

6、编辑path系统变量，添加路径（%ZOOKEEPER_HOME%bin）

7、打开命令窗口（cmd），输入"zkServer"，运行ZooKeeper

即成功，不要关闭该窗口。

三、安装Kafka 

 1、下载安装包：

链接：https://pan.baidu.com/s/10ifvEitQUoiKr762ZMnkdQ 
提取码：nkpq

2、解压安装包并进入安装目录，D:kafkakafka_2.11-2.4.0

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

4、找到"log.dirs"变量，修改为本地安装路径并拼接kafka-logs（log.dirs=D:kafkakafka_2.11-2.4.0kafka-logs）

5、找到"zookeeper.connect"变量，修改变量值（zookeeper.connect=localhost:2181）

6、kafka默认端口：9092；ZooKeeper默认端口2181

7、进入Kafka安装目录（D:kafkakafka_2.11-2.4.0），打开命令窗口，输入命令（第二条笔者测试无效）

.binwindowskafka-server-start.bat .configserver.properties
或binkafka-server-start.sh configserver.properties

-------- 效果展示 

 即成功，不要关闭该窗口。

四、测试

1、创建主题：打开新的命令窗口，输入命令（aaa即为主题名称）：

.binwindowskafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic aaa

-------- 效果展示 

2、查看主题：输入命令：

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

 -------- 效果展示 

3、创建生产者：输入命令（bbb即为生产者名称）：

.binwindowskafka-console-producer.bat --broker-list localhost:9092 --topic abc

  -------- 效果展示 （此为生产者窗口，需手动输入）

 即成功，不要关闭该窗口。

 4、创建消费者：进入Kafka安装目录，打开新的命令窗口，输入命令

 .binwindowskafka-console-consumer.bat --bootstrap-server localhost:9092 --topic abc  --from-beginning

 -------- 效果展示（在生产者窗口进行手动输入，消费者窗口显示数据）

 即成功。

5、查看topic,打开命令窗口，进入kafka安装目录，输入命令

.binwindowskafka-topics.bat --describe --zookeeper localhost:2181 --topic

 -------- 效果展示（笔者效果不佳，还未找到原因，欢迎大家投稿）

 参考地址：https://www.cnblogs.com/cwb123/p/13832836.html