windows安装kafka

一、安装JAVA JDK

1.下载安装包 http://www.oracle.com/technetwork/java/javase/downloads/jdk8-downloads-2133151.html

2、添加系统变量：JAVA_HOME=C:Program Files (x86)Javajdk1.8.0_144

（本机版本 jdk-15.0.1_windows-x64_bin.exe ）

 

二. 启动zookeeper

1.下载zookeeper http://zookeeper.apache.org/releases.html#download

（本机版本：apache-zookeeper-3.6.2-bin.tar.gz）

2.解压之后进入 path/conf目录

3.将zoo_sample.cfg 重命名为zoo.cfg

4.编辑zoo.cfg 找到并编辑 dataDir=D:\Kafka\zookeeper-3.4.9\tmp(必须以\分割)

5.添加环境变量：ZOOKEEPER_HOME=D:Kafkazookeeper-3.4.9

6.编辑path系统变量，添加路径 %ZOOKEEPER_HOME%in

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

8.打开命令窗口输入

> zkServer

就可以运行zookeeper啦；

 

 

 

三. 启动kafka

1.下载kafka http://kafka.apache.org/downloads 注意要下载二进制版本

（本机版本kafka_2.12-2.6.0.tgz）

2.解压进入kafka目录，进入config目录 打开server.properties

3.找到并编辑log.dirs=D:Kafkakafka_2.12-0.11.0.0kafka-logs

4.找到并编辑zookeeper.connect=localhost:2181 #端口根据上面zookeeper配置

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

>{$path}/bin/windows/kafka-server-start.bat {$path}/config/server.properties

# 注释：{$path}是你本机的kafka目录

 

 

四、测试阶段

#以下命令在 {$kafka目录}/bin/windows/ 下运行

1.创建一个topics

./kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic ShuaiGe

2.查看topics列表

./kafka-topics.bat --list --zookeeper localhost:2181

 

 

3.启动 生产者 和 消费者

#生产者

> ./kafka-console-producer.bat --broker-list localhost:9092 --topic ShuaiGe

 

#消费者

./kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic ShuaiGe --from-beginning

#--from-beginning 可选参数，意思是获取所有数据，不添加 则获取最新提交的数据