qidao123.com技术社区-IT企服评测·应用市场

标题: kafka4.0在windows体系下单击模式部署启动 [打印本页]

作者: 梦见你的名字    时间: 2025-4-18 03:14
标题: kafka4.0在windows体系下单击模式部署启动
完全没有用zookeeper而是采用kafka原生的KRaft部署(4.0版本摆脱了zookeeper的依靠)。全程window,没有用docker(几个加快镜像全失效了,近来就没怎么用),不包管100%乐成,本人也是摸石头过河,假如有错欢迎指正:
kafka4.0---启动。修改配置:

4.0完全丢弃了zookeeper的依靠(不过是用zookeeper也能用,如今zookeeper相关的配置文件与KRaft模式的配置文件好像是共用的,本人菜鸟没试过),本文是在完全的window体系中安装的,假如有linux情况大概主机上有docker也可以用,官网上有完整的教程,但是没有windows的--搞了很久才搞好。哭
官网网址:
  1. 下载:    https://kafka.apache.org/downloads
  2. 文档:    https://kafka.apache.org/documentation/#quickstart
复制代码
最好下载二进制版本-能够快速上手:

包管config\server.properties中:

  1. process.roles=controller,broker
  2. node.id=1
  3. listeners=PLAINTEXT://:9092,CONTROLLER://:9093
  4. controller.listener.names=CONTROLLER  
  5. listener.security.protocol.map=CONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT  
  6. controller.quorum.voters=1@localhost:9093
  7. log.dirs=D:\\kafka_4.0\\kafka_2.13-4.0.0\\logs
  8. num.partitions=1        
复制代码
包管这个路径存在,不存在自己创建:

  1. log.dirs=D:\\kafka_4.0\\kafka_2.13-4.0.0\\logs
复制代码
Kafka 4.0 安装配置全流程总结(Windows 情况)

1. 初始准备


2. 解压与目录布局


3. 须要配置修改

(1) 修改 config/server.properties!!最好把文件中的中文注解删除,大概会有编码错误

properties
复制
  1. # KRaft 模式核心配置
  2. process.roles=controller,broker
  3. node.id=1
  4. listeners=PLAINTEXT://:9092,CONTROLLER://:9093
  5. controller.listener.names=CONTROLLER
  6. listener.security.protocol.map=CONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT
  7. controller.quorum.voters=1@localhost:9093
  8. log.dirs=D:\\kafka_4.0\\kafka_2.13-4.0.0\\logs  # 使用双反斜杠或正斜杠
  9. num.partitions=1
复制代码
(2) 配置 Log4j 2.x


4. 初始化存储目录

cmd下令行中
先进入你的bin\window目录,然后启动下令行


  1. cd D:\kafka_4.0\kafka_2.13-4.0.0\bin\windows
  2. kafka-storage.bat random-uuid  # 生成集群ID(如 ABC123...)
  3. kafka-storage.bat format -t ABC123... -c ..\..\config\server.properties
复制代码

5. 启动 Kafka

cmd
第二个参数:“server.properties的路径务必注意,..\表示上一级。请根据你的目录具体更改”
  1. kafka-server-start.bat ..\..\config\server.properties
复制代码

查抄你的logs目录下有没有这个文件:

有了就乐成了
6. 测试功能

新开一个cmd,还是进入windows目录

  1. # 创建 Topic
  2. kafka-topics.bat --create --bootstrap-server localhost:9092 --topic test
  3. # 生产消息
  4. kafka-console-producer.bat --bootstrap-server localhost:9092 --topic test
  5. # 消费消息
  6. kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning
复制代码
7. 关机与重启



关键注意事项


常见题目速查

题目征象办理方案启动时报 meta.properties not found重新实行 kafka-storage.bat format端口冲突修改 server.properties 中的 listeners 端口Java 版本错误查抄 java -version 是否为 JDK 17日记目录未天生查抄 log.dirs 路径权限和拼写 按此流程操作后,Kafka 将保持恒久化状态,重启后无需重复配置。

下一次重启:只必要输入:

  1. kafka-server-start.bat ..\..\config\server.properties
复制代码
免责声明:如果侵犯了您的权益,请联系站长,我们会及时删除侵权内容,谢谢合作!更多信息从访问主页:qidao123.com:ToB企服之家,中国第一个企服评测及商务社交产业平台。




欢迎光临 qidao123.com技术社区-IT企服评测·应用市场 (https://dis.qidao123.com/) Powered by Discuz! X3.4