我经常更新Kafka主题中的所有当前消息 retention.ms 到10。这使得所有的消息都将在10毫秒后过期。但是，有时，消息无法通过这种方式清除。我不得不删除并重新创建主题，以便清理所有消息。我不确定它是否与这个问题有关，但它经常发生在所有该主题的消费者由于某种原因停止工作之后。根本原因是什么？
retention.ms
inn6fuwd1#
这个 retention.ms 字段是日志清理器的最短时间。日志清理器每隔一段时间只运行一次（kafka文档状态为300000 ms），因此您可能需要等待它运行。
1条答案
按热度按时间inn6fuwd1#
这个
retention.ms字段是日志清理器的最短时间。日志清理器每隔一段时间只运行一次（kafka文档状态为300000 ms），因此您可能需要等待它运行。