spring-kafka入门学习（一）：kafka的安装与启动
目录一、软件版本的选择
二、安装zookeeper
1下载zookeeper
2配置zookeeper
3启动zookeeper
三、安装kafka
1下载kafka
2配置kafka
3启动kafka
四、测试
一、软件版本的选择
二、安装zookeeper
Kafka 使用 Zookeeper 保存集群的元数据信息和消费者信息。
1下载zookeeper
选择版本3.4.6，解压到D:\java目录
2配置zookeeper
在D:\java\zookeeper-3.4.6\conf中把zoo_sample.cfg修改为zoo.cfg文件
在D:\java\zookeeper-3.4.6创建2个文件夹并增加配置
dataDir=D:\\java\\zookeeper-3.4.6\\data
dataLogDir=D:\\java\\zookeeper-3.4.6\\log
注意：文件夹分割符一定要是”\\”
3启动zookeeper
然后cmd进入D:\java\zookeeper-3.4.6\bin目录
执行zkServer.cmd即可启动Zookeeper
启动成功
三、安装kafka
1下载kafka
http://kafka.apache.org/downloads.html
选择版本2.12-2.1.1，解压到D:\java目录
2配置kafka
在D:\java\kafka_2.12-2.1.1目录新建kafka-logs文件夹
进入到config目录，修改service.properties里面log.dirs路径log.dirs=D:\\java\\kafka_2.12-2.1.1\\kafka-logs
注意：文件夹分割符一定要是”\\”
3启动kafka
在D:\java\kafka_2.12-2.1.1目录run_kafka.bat文件，添加如下内容
.\bin\windows\kafka-server-start.bat .\config\server.properties
启动kafka报错：'wmic' 不是内部或外部命令，也不是可运行的程序
原因：在环境变量中查看变量名Path下的变量值是否有以下信息，没有则添加上：
%SystemRoot%;%SystemRoot%\system32;%SystemRoot%\System32\Wbem
启动成功
四、测试
进入D:\java\kafka_2.12-2.1.1\bin\windows目录
1创建topic主题
kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
2创建生产者
kafka-console-producer.bat --broker-list localhost:9092 --topic test
3创建消费者
kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning
4在生产者的黑窗口出入”a”，在消费者的黑窗口能收到”a”
注意：不要关闭生产者和消费者的窗口
参考书籍：《Kafka权威指南》
https://blog.51cto.com/u_14998860/4867427
页:
[1]