免费网站主机空间百度怎么做网站排名
测试环境服务器上面删除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本次处理到此就结束了