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权威指南》