我有几个经纪人负责处理一些应用程序的数据。我为所有代理启用了日志清理器 cleanup.policy
作为删除。几周前有一个问题,日志清理器在其中一个代理中停止工作,这导致了磁盘的完全使用,而且无法检测到。
我正在寻找一种有效的方法来检查代理的日志清理器是否停止工作。
首先,我使用的是Kafka1.0.2版本。
作为一种简单的方法,我尝试了查看日志清理器的日志,当日志在相当长的时间内不更新时,意味着日志清理器停止工作。
但是,一些代理的日志清理器的日志由于某种原因没有得到更新,即使日志清理器正在运行(可以理解,因为应用程序的日志大小在经过相当长的时间后并没有继续增加)。
我试过和几个配置玩 log.cleaner.min.cleanable.ratio
, log.retention.check.interval.ms
等等,为什么日志清洁器的日志没有得到更新,但我不能得出任何结论。关于如何检查日志清理器是否正在运行或者为什么日志清理器的日志不会记录有什么想法吗?
tldr公司;
Kafka经纪人的日志清理器停止工作,无法及时检测到它,因此出现了一些问题。寻找一种有效的方法来检查日志清理器的终止。
暂无答案!
目前还没有任何答案,快来回答吧!