news 2026/6/1 17:25:08

kafka使用kraft

作者头像

张小明

前端开发工程师

1.2k 24
文章封面图
kafka使用kraft

window

使用kafka-storage生成生成一个uuid

.\kafka-storage.bat random-uuid

格式化存储

.\kafka-storage.batformat-t对应的uuid--configD:\configure\fisher\kafka\config\kraft\server.properties

启动命令

.\kafka-server-start.bat D:\configure\fisher\kafka\config\kraft\server.properties

linux

解压kafka

tar-zxvfkafka_2.13-3.8.1.tgz

改文件夹名称

mvkafka_2.13-3.8.1 /data/kafka

进入bin目录执行使用kafka-storage生成生成一个uuid

./kafka-storage.sh random-uuid

然后去修改config/kraft/server.properties

# 表示此节点,既是broker又可以当controllerprocess.roles=broker,controller# 节点id,不重名即可node.id=1# controller竞争者,也就是controller将从它们之中诞生(这里的kafka1是刚刚设置的本机的域名解析,或者直接写localhost也行)controller.quorum.voters=1@localhost:9093listeners=PLAINTEXT://:9092,CONTROLLER://:9093# 监听地址(也就是客户端连接时访问的地址)advertised.listeners=PLAINTEXT://localhost:9092controller.listener.names=CONTROLLER# kafka数据存放地址log.dirs=data

格式化存储

./kafka-storage.shformat-t对应的uuid--config/data2/kafka/config/kraft/server.properties

启动命令 (守护进程启动加-daemon 参数)

./kafka-server-start.sh-daemon/data/kafka/config/kraft/server.properties

问题
启动后server.log输出异常,server.properties路径有问题

[2026-05-3120:01:21,702]INFO Registered kafka:type=kafka.Log4jController MBean(kafka.utils.Log4jControllerRegistration$)[2026-05-3120:01:21,994]ERROR Exiting Kafka due to fatal exception(kafka.Kafka$)java.nio.file.NoSuchFileException: /data/kafka/config/kraft/server.properties at sun.nio.fs.UnixException.translateToIOException(UnixException.java:86)at sun.nio.fs.UnixException.rethrowAsIOException(UnixException.java:102)at sun.nio.fs.UnixException.rethrowAsIOException(UnixException.java:107)at sun.nio.fs.UnixFileSystemProvider.newByteChannel(UnixFileSystemProvider.java:214)at java.nio.file.Files.newByteChannel(Files.java:361)at java.nio.file.Files.newByteChannel(Files.java:407)at java.nio.file.spi.FileSystemProvider.newInputStream(FileSystemProvider.java:384)at java.nio.file.Files.newInputStream(Files.java:152)at org.apache.kafka.common.utils.Utils.loadProps(Utils.java:653)at kafka.Kafka$.getPropsFromArgs(Kafka.scala:50)at kafka.Kafka$.main(Kafka.scala:89)at kafka.Kafka.main(Kafka.scala)
版权声明: 本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若内容造成侵权/违法违规/事实不符,请联系邮箱:809451989@qq.com进行投诉反馈,一经查实,立即删除!
网站建设 2026/6/1 17:23:46

Agent 一接操作审计就开始把“看到过”当“做过”:从 Evidence Window 到 Action Proof 的工程实战

很多团队把 Agent 接进操作后台后,第一反应是把日志打全。可事故复盘里最常见的问题不是没日志,而是 Agent 把看过的证据和做过的动作混成一件事。它读到一条旧的“已禁用账号”记录,就以为这次工单也完成了禁用;或者看到旁路成功…

作者头像 李华
网站建设 2026/6/1 17:22:13

微星叫板雷蛇“老婆机”,宣称有能互动台式机,能否成真?

微星叫板雷蛇,推出互动台式机概念 微星为了不被雷蛇的“老婆机”胶囊比下去,宣称拥有一款“不仅能运行游戏,还能响应、适应并互动”的台式电脑。这一宣称无疑给市场带来了新的关注点。 虚实难辨:产品详情待解 目前微星并未透露这款…

作者头像 李华
网站建设 2026/6/1 17:19:00

功能堆砌不如好扩展:4 款开源商城系统的选型思考

功能只是起点,真正决定系统寿命的是扩展能力和维护成本随着私域电商、小程序商城、社区团购、连锁门店和企业自营平台的快速发展,越来越多的企业开始选择开源商城系统来搭建自己的业务平台。但在实际选型过程中,很多团队都会面临同一个问题&a…

作者头像 李华
网站建设 2026/6/1 17:15:33

实战解析:如何通过邮箱地址高效获取关联手机号码

实战解析:如何通过邮箱地址高效获取关联手机号码 【免费下载链接】email2phonenumber A OSINT tool to obtain a targets phone number just by having his email address 项目地址: https://gitcode.com/gh_mirrors/em/email2phonenumber 在数字身份安全研究…

作者头像 李华