我要评论目录
一、安装zookeeper
1、 下载安装包
apache zookeeper
http://zookeeper.apache.org/releases.html#download（我本地下载的是3.7.1版本）
2、 解压并进入zookeeper目录，如：d:\software\kafka\apache-zookeeper-3.7.1-bin
3、 将“zoo_sample.cfg”重命名为“zoo.cfg”
4、 打开“zoo.cfg”找到并编辑datadir=d:\\software\\kafka\\apache-zookeeper-3.7.1-bin\\tmp(必须使用\分割)
5、 添加系统变量：zookeeper_home=d:\software\kafka\apache-zookeeper-3.7.1-bin
6、 编辑path系统变量，添加路径：%zookeeper_home%\bin
7、 在zoo.cfg文件中修改默认的zookeeper端口clientport=2181（默认端口2181）
8、 打开新的cmd，输入“zkserver“，运行zookeeper
9、 命令行提示如下：说明本地zookeeper启动成功
注意：不要关了这个窗口
二、安装kafka
1、 下载安装包
apache kafkaapache kafka: a distributed streaming platform.
http://kafka.apache.org/downloads（我本地安装的是kafka_2.12-2.8.1）
注意要下载二进制版本
2、 解压并进入kafka目录，本人：d:\software\kafka\kafka_2.12-2.8.1
3、 进入config目录找到文件server.properties并打开
4、 找到并编辑log.dirs=d:\software\kafka\kafka_2.12-2.8.1\kafka-logs,d:\\software\\kafka\\kafka_2.12-2.8.1\\kafka-logs
5、 找到并编辑zookeeper.connect=localhost:2181
6、 kafka会按照默认，在9092端口上运行，并连接zookeeper的默认端口：2181
7、 进入kafka安装目录d:\software\kafka\kafka_2.12-2.8.1，按下shift+右键，选择“打开命令窗口”选项，打开命令行，输入：
.\bin\windows\kafka-server-start.bat .\config\server.properties
或bin\kafka-server-start.sh config\server.properties
注意：注意：不要关了这个窗口，启用kafka前请确保zookeeper实例已经准备好并开始运行
三、黑窗口测试生产者、消费者
1、 创建主题，进入kafka安装目录d:\software\kafka\kafka_2.12-2.8.1，按下shift+右键，选择“打开命令窗口”选项，打开命令行，输入：
.\bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic jun
2、查看主题输入：
.\bin\windows\kafka-topics.bat --list --zookeeper localhost:2181
我本地是有俩个主题
3、 创建生产者，黑窗口输入：
.\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic jun
输入消息后回车
注意：不要关了这个窗口
4、 创建消费者，进入kafka安装目录d:\software\kafka\kafka_2.12-2.8.1，按下shift+右键，选择“打开命令窗口”选项，打开命令行，输入：
.\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic jun --from-beginning
此时，往生产者窗口写入消息，消费者窗口也能同步
发表评论