为什么卡夫卡崩溃？

【问题标题】：Why kafka crash?为什么卡夫卡崩溃？
【发布时间】：2020-06-30 08:08:46
【问题描述】：

我有卡夫卡 2.5.0 我的服务卡夫卡有时会崩溃。

kafka/logs/server.log

[09:25:23,316] WARN Unable to read additional data from client sessionid 0x1000001a8fd0012, likely client has closed socket (org.apache.zookeeper.server.NIOServerCnxn)

/var/log/messages

09:25:23 kafka1 systemd: kafka.service: main process exited, code=exited, status=1/FAILURE
09:25:23 kafka1 systemd: Unit kafka.service entered failed state.
09:25:23 kafka1 systemd: kafka.service failed.

如何找出发生这种情况的原因？

【问题讨论】：

标签： apache-kafka

【解决方案1】：

如果 Zookeeper 正在运行，请先检查它。

如果它正在运行，请尝试在 zoo.cfg 中更改这些设置：

autopurge.snapRetainCount=15 (at least)
autopurge.purgeInterval=1 - 2 hours

这里可能有一些提示：

zookeeper + Unable to read additional data from client session id

ZooKeeper keeps getting EndOfStreamException, causing a crash

【讨论】：

它几乎可以是一切：Zookeeper 可能过于频繁地清除，日志条目过多，2 个不同的 Zookeeper 服务器的 id 相同