惯性聚合 高效追踪和阅读你感兴趣的博客、新闻、科技资讯
阅读原文 在惯性聚合中打开

推荐订阅源

D
Docker
B
Blog RSS Feed
Microsoft Security Blog
Microsoft Security Blog
Y
Y Combinator Blog
N
Netflix TechBlog - Medium
M
MIT News - Artificial intelligence
奇客Solidot–传递最新科技情报
奇客Solidot–传递最新科技情报
B
Blog
钛媒体:引领未来商业与生活新知
钛媒体:引领未来商业与生活新知
C
Check Point Blog
The GitHub Blog
The GitHub Blog
让小产品的独立变现更简单 - ezindie.com
让小产品的独立变现更简单 - ezindie.com
P
Proofpoint News Feed
Martin Fowler
Martin Fowler
大猫的无限游戏
大猫的无限游戏
GbyAI
GbyAI
博客园_首页
A
About on SuperTechFans
Blog — PlanetScale
Blog — PlanetScale
人人都是产品经理
人人都是产品经理
T
Tailwind CSS Blog
aimingoo的专栏
aimingoo的专栏
T
The Blog of Author Tim Ferriss
The Cloudflare Blog

博客园 - SimpleSmile

Axure10 在线编辑echart mysql获取库内所有表ddl结构说明 pip升级 关于SpringBoot的valid校验运行原理-自学 centos下python3.6.8 安装ssl模块 windows根据文件名找到进程,并杀死进程。 Oracle关联表进行修改操作(查询某个表,以某个表作为基础,修改其它表) 解决CentOS 7.x虚拟机无法上网的问题 ORA-00972: identifier is too long异常处理 resttemplate 由于框架原因自带了转xml方式,不改变框架底层情况下,修复为返回json格式 java 操作excel 当jar包执行时,内嵌的文件找不到时,可以这样解决! Email Windows发送成功,Linux却发送失败的可能原因 解决linux时间转换为yyyy-MM-dd md5加密中文windows和linux不一致 【WebDriver实战问题】selenium调用IE11浏览器,报错“找不到元素” mysql sql查询中文正常,而jdbc查询出来是byte[]类型处理 单表递归,查询组织及其自组织的内容信息 vi 关闭自动缩进 python 读写word
windows环境下安装kafka
SimpleSmile · 2025-08-15 · via 博客园 - SimpleSmile
版本:(参考:https://cloud.tencent.com/developer/article/2153563)
jdk java version "1.8.0_31" (环境变量配置自行配置忽略)
zookeeper : 3.9.3
kafka : kafka_2.12-3.9.1
zookeeper 下载地址:https://dlcdn.apache.org/zookeeper/zookeeper-3.9.3/  (要下载二进制的文件夹)
kafka 下载地址:https://kafka.apache.org/downloads
1.安装zookeeper
1.1 解压apache-zookeeper-3.9.3-bin.tar.gz  
1.2 进入zookeeper目录,如:D:\\Kafka\\apache-zookeeper-3.9.3-bin\\apache-zookeeper-3.9.3-bin\\conf
1.3 将“zoo_sample.cfg”重命名为“zoo.cfg”
1.4 打开“zoo.cfg”找到并编辑dataDir=D:\\Kafka\\zookeeper-3.4.9\\tmp(必须以\\分割)
1.5 增加配置参数 audit.enable=true
1.6 添加系统变量:ZOOKEEPER_HOME=D:\Kafka\zookeeper-3.4.9
1.7 编辑path系统变量,添加路径:%ZOOKEEPER_HOME%\bin
1.8 在zoo.cfg文件中修改默认的Zookeeper端口(默认端口2181)
1.9 打开新的cmd,输入“zkServer“,运行Zookeeper

image

2.安装kafka(这里一定要注意,目录不要太深,不然无法启动)(参考:https://blog.csdn.net/qq_43513957/article/details/135367201)
2.1 解压kafka_2.12-3.9.1.tgz
2.2 进入kafka目录,如:D:\\kafka\\kafka_2.12-3.9.1\\config
2.3 找到文件server.properties并打开
2.4 找到并编辑log.dirsD:\\Kafka\\kafka_2.12-3.9.1\\kafka-logs
2.5 找到并编辑zookeeper.connect=localhost:2181
2.6 Kafka会按照默认,在9092端口上运行,并连接zookeeper的默认端口:2181
2.7 启动命令:.\bin\windows\kafka-server-start.bat .\config\server.properties

image

3. 测试,创建topic(参考:https://developer.aliyun.com/article/1372261)
.\bin\windows\kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test

image

4.测试 创建生产者
 .\bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic test

image

不关闭生产者的情况下,再打开一个窗口,启动一个消费者进行监听数据...
D:\kafka_2.12-3.9.1> .\bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning

image