Windows下安装Kafka

1、安装JDK

2、安装zooeleeper

下载安装包：http://zookeeper.apache.org/releases.html#download

下载后解压到一个目录：

1.进入Zookeeper设置目录，笔者D:\Java\Tool\zookeeper-3.4.6\conf
2. 将“zoo_sample.cfg”重命名为“zoo.cfg”
3. 在任意文本编辑器（如notepad）中打开zoo.cfg
4. 找到并编辑dataDir=D:\\Java\\Tool\\zookeeper-3.4.6\\tmp
5. 与Java中的作法相似，咱们在系统环境变量中添加：
　　a. 在系统变量中添加ZOOKEEPER_HOME = D:\Java\Tool\zookeeper-3.4.6
　　b. 编辑path系统变量，添加为路径%ZOOKEEPER_HOME%\bin;
6. 在zoo.cfg文件中修改默认的Zookeeper端口（默认端口2181）
7. 打开新的cmd，输入zkServer，运行Zookeeper。
8. 命令行提示以下：说明本地Zookeeper启动成功

 

3、安装与运行Kafka

下载：

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

下载后解压到任意一个目录F:/kafka_2.11-0.10.0.1

1. 进入Kafka配置目录，F:/kafka_2.11-0.10.0.1
2. 编辑文件“server.properties”
3. 找到并编辑log.dirs=F:/kafka_2.11-0.10.0.1/kafka-log,这里的目录本身修改为本身喜欢的
4. 找到并编辑zookeeper.connect=localhost:2181。表示本地运行
5. Kafka会按照默认，在9092端口上运行，并链接zookeeper的默认端口：2181。

运行：

重要：请确保在启动Kafka服务器前，Zookeeper实例已经准备好并开始运行。

1.进入Kafka安装目录F:/kafka_2.11-0.10.0.1
2.按下Shift+右键，选择“打开命令窗口”选项，打开命令行。
3.如今输入

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

并回车

 

4、测试（上面的Zookeeper和kafka一直打开）

（1）、建立主题

1.进入Kafka安装目录D:\Java\Tool\kafka_2.11-0.10.0.1
2.按下Shift+右键，选择“打开命令窗口”选项，打开命令行。
3.如今输入

./bin/windows/kafka-console-consumer.bat --zookeeper localhost:2181 --topic helloworld

并回车

（2）建立生产者

1.进入Kafka安装目录D:\Java\Tool\kafka_2.11-0.10.0.1
2.按下Shift+右键，选择“打开命令窗口”选项，打开命令行。
3.如今输入

./bin/windows/kafka-console-producer.bat --broker-list localhost:9092 --topic helloworld

并回车

（3）建立消费者

1.进入Kafka安装目录D:\Java\Tool\kafka_2.11-0.10.0.1
2.按下Shift+右键，选择“打开命令窗口”选项，打开命令行。
3.如今输入

./bin/windows/kafka-console-consumer.bat --zookeeper localhost:2181 --topic helloworld

并回车

而后在生产者窗口中输入内容并回车，便可在消费者窗口看到消息。