当 kafka 日志回滚时会发生什么？消费者是否错过了旧日志文件中的消息？

Question

假设我刚刚在 Kafka 中添加了导致日志翻转的消息。因此，此消息和紧接其前的消息现在位于 archived/rolled 日志文件中。我是否错过了这些消息，换句话说，如果现在有消费者出现，它不会收到这些消息吗？ Kafka 是如何处理这种场景的？

Answer 1

您仍然可以在已滚动的日志段中检索消息，从消费者的角度来看，您不会注意到任何差异。在达到保留条件并删除旧日志段之前，消息可供使用。