
window下安装kafka
打开配置文件 按照以下修改配置: 将默认配置文件 打开 根据实际网络环境,设置以下配置:
发布日期:2021-05-17 22:23:32
浏览次数:18
分类:精选文章
本文共 1509 字,大约阅读时间需要 5 分钟。
安装Zookeeper和Kafka环境配置
为了搭建一个功能齐全的分布式系统环境,以下将详细介绍Zookeeper和Kafka的安装与配置步骤。这些步骤适用于Windows操作系统,按照顺序执行即可成功完成环境安装。
下载必要软件包
下载Zookeeper
- 进入官方下载页面:Apache Zookeeper下载地址
- 解压压缩文件,将其安Comicplacement在合适的路径位置(建议放在
D:\Program Files\
下)。
下载Kafka
- downloading Kafka package:
- Kafka下载地址
- 解压压缩包,安装路径与Zookeeper保持一致。
安装Zookeeper
解压安装包
- 双击
zookeeper-3.4.10.tar.gz
进行解压ervalues,选择默认路径D:\Program Files\zookeeper-3.4.10
。
配置Zookeeper
zoo.cfg
,位于D:\Program Files\zookeeper-3.4.10\conf
目录下。dataDir=D:\Program Files\zkdata
zoo_sample.cfg
重命名为zoo.cfg
。启动Zookeeper服务
- 找到
zookeeper-3.4.10\bin\zookeeper.cmd
文件,双击运行。 - 服务启动后,通过浏览器访问Zookeeper管理界面:
http://localhost:2181
安装Kafka
解压Kafka包
- 双击
kafka_2.11-1.1.0.tgz
,解压到D:\Program Files\kafka_2.11-1.1.0
路径下。
修改Kafka配置
server.properties
,位于D:\Program Files\kafka_2.11-1.1.0\config
。brokers = localhost:9092
listenerillet= KafkaListener.java
- 其他自定义配置可根据需求修改。
启动Kafka服务
- 双击
kafka-server-start.bat
文件,输入命令:.\bin\windows\kafka-server-start.bat .\config\server.properties
- 服务启动后,团队成员可以通过
localhost:9092
进行消息生产和消费。
测试环境
创建主题
- 在终端执行命令:
kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
- 成功创建一个名为
test
的主题。
消息生产
- 使用生产者工具:
kafka-console-producer.bat --broker-list localhost:9092 --topic test
- 按下回车,输入消息内容,按Enter发送。
消息消费
- 使用消费者工具:
kafka-console-consumer.bat --zookeeper localhost:2181 --topic test
- 消息将显示在终端中。
启用环境摘要
通过以上步骤,您已经成功搭建了一个基本的Zookeeper和Kafka环境。环境已包含必要的服务启动,接下来可根据实际需求进行扩展配置,如添加更多broker、设置复制因子等高级功能。
如果有任何问题,可以参考官方文档或社区资源,进一步优化配置以应对特定场景需求。
发表评论
最新留言
不错!
[***.144.177.141]2025年04月30日 01时25分32秒
关于作者

喝酒易醉,品茶养心,人生如梦,品茶悟道,何以解忧?唯有杜康!
-- 愿君每日到此一游!
推荐文章
MVVM_Template
2019-03-14
{spring.cloud.client.ipAddress}
2019-03-14
栈上内存溢出漏洞利用之Return Address
2019-03-14
Bugku CTF web29(Web)
2019-03-14
网络+图片加载框架(英文版)
2019-03-14
扣非净利润连续三年亏损,四维图新如何熬过“转型阵痛期”?
2019-03-14
前台报Invalid Host/Origin Header错误
2019-03-14
IE浏览器中input的placeholder不显示
2019-03-14
【CSP - S T1】格雷码
2019-03-14
Python imageio方法示例
2019-03-14
Possible missing firmware
2019-03-14
算法的学习方式
2019-03-14
JAVA BigInteger和BigDecimal类常用方式
2019-03-14
深度学习框架 各种模型下载集合 -- models list
2019-03-14
双层卷积神经网络--tf
2019-03-14
six.move 的作用
2019-03-14
MySQL(九)SQL优化
2019-03-14
Django认证系统
2019-03-14