【发布时间】:2020-11-02 22:07:32
【问题描述】:
如果 kafka 主题中的事件由于保留策略而过期,是否有任何机制(通过特定日志文件条目或类似条目)获得通知? (我知道这应该通过设计避免,但仍然如此)。
我知道用于监控已发布事件和相关消费者组之间偏移差异的消费者滞后监控工具,但它们仅提供 afaik 数字(偏移差异)。
换句话说:我们如何知道 kafka 事件是否从未被消费过并因此过期?
【问题讨论】:
标签: apache-kafka
如果 kafka 主题中的事件由于保留策略而过期,是否有任何机制(通过特定日志文件条目或类似条目)获得通知? (我知道这应该通过设计避免,但仍然如此)。
我知道用于监控已发布事件和相关消费者组之间偏移差异的消费者滞后监控工具,但它们仅提供 afaik 数字(偏移差异)。
换句话说:我们如何知道 kafka 事件是否从未被消费过并因此过期?
【问题讨论】:
标签: apache-kafka
日志清理线程会将删除事件输出到代理日志,但它会反映文件段而不是特定消息
【讨论】: