假设我刚刚添加了一条消息,导致Kafka的日志翻滚。因此,此消息及其前一条消息现在位于存档/滚动日志文件中。我是否错过了这些消息,换句话说,如果现在有消费者出现,它将不会收到这些消息?Kafka是如何处理这种情况的?
gupuwyp21#
您仍然能够检索已滚动的日志段中的消息,并且从消费者的Angular 来看,您不会注意到任何差异。在达到保留条件并删除旧的日志段之前,邮件可供使用。
1条答案
按热度按时间gupuwyp21#
您仍然能够检索已滚动的日志段中的消息,并且从消费者的Angular 来看,您不会注意到任何差异。在达到保留条件并删除旧的日志段之前,邮件可供使用。