0
比方说,我刚刚添加了一条消息,导致卡夫卡的日志滚动。因此,此消息及其紧前面的消息现在位于归档/滚动日志文件中。换言之,如果现在消费者出现,它会不会收到这些消息吗?卡夫卡如何处理这种情况?当kafka日志翻转时会发生什么?消费者是否错过旧日志文件中的消息?
比方说,我刚刚添加了一条消息,导致卡夫卡的日志滚动。因此,此消息及其紧前面的消息现在位于归档/滚动日志文件中。换言之,如果现在消费者出现,它会不会收到这些消息吗?卡夫卡如何处理这种情况?当kafka日志翻转时会发生什么?消费者是否错过旧日志文件中的消息?
您仍然可以检索已滚动的日志段中的消息,从消费者的角度来看,您不会注意到任何差异。消息可用于消耗,直到达到保留标准并删除旧的日志段。