1.准备工作
1.1 java环境
1.2 下载并解压到D:\zookeeper-3.4.13 下载并解压到 D:\kafka_2.12-2.1.0
2.安装zookeeper 、kafka 我安装在d盘根目录下
2.1 D:\zookeeper-3.4.13\conf => zoo_sample.cfg重命名为zoo.cfg 并修改zoo.cfg 节点
dataDir=D:/data/logs/zookeeper
2.2 D:\kafka_2.12-2.1.0\config=> 并修改log.dirs 节点
log.dirs=D:/data/logs/kafka
备注：路径要么是"/"分割，要么是转义字符"\\"
2.3配置环境变量
ZOOKEEPER_HOME: D:\zookeeper-3.4.13
Path后追加 ;%ZOOKEEPER_HOME%\bin;
3.启动zookeeper 、kafka
3.1启动zookeeper
3.2启动Kafka
命令：.\bin\windows\kafka-server-start.bat .\config\server.properties cmd 切换到 D:\kafka_2.12-2.1.0下执行
4.测试kafka
4.1 创建topic
命令：kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
备注：以上依次显示创建topic 和查询topic
4.2 开启生产者 消费者
生产者命令：kafka-console-producer.bat --broker-list localhost:9092 --topic test
消费者命令：kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning
