欢迎来到尧图网

客户服务 关于我们

您的位置:首页 > 科技 > 名人名企 > kafka删除/创建 topic报错,如何解决

kafka删除/创建 topic报错,如何解决

2025/3/31 19:18:15 来源:https://blog.csdn.net/bltyu2000/article/details/146473617  浏览:    关键词:kafka删除/创建 topic报错,如何解决

测试环境服务器上面删除topic失败

sh kafka-topics.sh --bootstrap-server 127.0.0.1:9092 --delete --topic yidun_image_human_result

错误截图

然后查看server.log日志后看到expiring session...错误。可知是会话参数配置有问题

同时查看9092的端口查看也没了。

到此可以基本判断kafka服务挂掉了。是因为会话参数配置的有问题。此时我们先配置server.properties文件。修改添加或者修改这个参数的值

zookeeper.session.timeout.ms 是 Kafka 依赖 ZooKeeper 的核心参数,直接影响集群的稳定性、故障恢复速度和元数据一致性

 ​这个参数与 ZooKeeper 的 tickTime 关联
ZooKeeper 的 tickTime(基础时间单位,如 2000ms)决定了会话超时计算的粒度。
​公式:session.timeout.ms 必须是 tickTime 的整数倍,且需在 ZooKeeper 的 minSessionTimeout 和 maxSessionTimeout 范围内。
​示例:若 ZooKeeper 的 tickTime=2000ms,则 session.timeout.ms 可设置为 4000ms(2 倍 tickTime)至 40000ms(20 倍 tickTime)。

zookeeper.session.timeout.ms=30000

核心作用:

​会话心跳机制
临时节点生命周期管
用于检测 ZooKeeper 服务端异常或网络中断。

修改完后重启kafka服务

# 以守护进程模式启动(后台运行)
./kafka-server-start.sh -daemon ../config/server.properties

然后查看日志,如下输出说明没问题了

然后查看9092端口监听信息,会输出相关的服务信息即为正常

netstat -ant | grep 9092 

最后再次执行创建topic的命令即可成功创建topic。

sh kafka-topics.sh --bootstrap-server 127.0.0.1:9092 --create --partitions 12 --replication-factor 1 --topic yidun_image_human_result

然后使用命令检查创建的topic是否存在即可

# 检查 Topic 状态
./kafka-topics.sh --bootstrap-server localhost:9092 --describe

本次处理到此就结束了

版权声明:

本网仅为发布的内容提供存储空间,不对发表、转载的内容提供任何形式的保证。凡本网注明“来源:XXX网络”的作品,均转载自其它媒体,著作权归作者所有,商业转载请联系作者获得授权,非商业转载请注明出处。

我们尊重并感谢每一位作者,均已注明文章来源和作者。如因作品内容、版权或其它问题,请及时与我们联系,联系邮箱:809451989@qq.com,投稿邮箱:809451989@qq.com

热搜词