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

[python] spring-kafka入门学习（一）：kafka的安装与启动

相关帖子

NoteExpress插件在word中不显示怎么解决？

win10显示虚拟网卡未安装怎么解决虚拟网卡未安装解决方法

驱动精灵nvidia安装程序失败怎么办？具体解决方法分享

office2010安装包电脑安装方法

win10安装ie8提示系统不支持如何解决？

Virtualbox增强功能安装不了怎么办？

itunes安装出错解决方法

U盘安装win7详细教程

硬盘安装win7系统详细步骤

电脑如何安装音频设备

三叶草 LV3