2018-07-23 Window系统下安装kafka消息中间件

1.kafka简介

kafka是一种高吞吐量的分布式订阅消息系统，它可以处理消费者规模的网站中所有动作流数据。   

2. 下载所需安装包

java下载路径
zookeeper下载路径
kafka下载路径

3. java环境安装

a.java的安装就不详细说了，jdk-8u181-windows-i586.exe双击安装包，选择安装目录，其他的直接默认就可以了.注意配置环境变量

)

环境变量配置：

4. zookeeper安装

4.1下载好zookeeper-3.4.12.tar.zip安装包后，解压到当前目录。

4.2.zookeeper配置：

1. 进入到conf目录，复制zoo_sample.cfg文件，命名为zoo.zfg;

2. 修改zoo.cfg文件，将其data输出目录指定一下，可自行创建一个文件。修改器目录

3. 启动zookeeper: 进入到zookeep解压缩跟目录下，打开cmd界面，输入：bin\windows\zookeeper-server-start.bat config\zookeeper.properties，回车

)

5. kafka安装

5.1 进入kafka的配置目录下(E:\SpringBootTools\kafka_2.12-1.1.0\config).

5.2 编辑文件"server.properties"

5.3 找到并编辑log.dirs=E:\SpringBootTools\kafka_2.12-1.1.0\kafka-log(将目录修改成自己喜欢的目录即可)大概60行

5.4 找到并编辑：zookeeper.connect=localhost:2181，表示本地运行。

5.5 启动kafka，进入到跟目录下，Shift+右键，选择打开“在此处打开Powershell窗口”。输入：.\bin\windows\kafka-server-start.bat .\config\server.properties

5.6 注意：重要的事情说三遍！！！启动kafka之前，一定要启动zookeeper，否则会报
java.net.ConnectException: Connection refused: no further information 异常

6. 测试kafka是否按照成功

6.1. 创建主题Topic:命令行窗口下输入：

 .\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication -factor 1 --partitions 1 --topic mytopic

6.2 查看创建的Topic列表：

.\bin\windows\kafka-topics.bat --list --zookeeper localhost:2181

6.3 打开Producer:打开一个新的命令窗口输入：

.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic mytopic

6.4 打开Consumer:新打开一个命令窗口输入：

 .\bin\windows\kafka-console-consumer.bat --zookeeper localhost:2181 --topic mytopic 

6.5 Producer和Consumer窗口不要关闭，在Producer中输入信息，发现Consumer中可以接受到消息。