在卡夫卡乱序处理的消息流

问题描述 投票:0回答:1

我最近碰到这篇文章上的Apache卡夫卡文档随同关于乱序消息的处理卡夫卡流

https://kafka.apache.org/21/documentation/streams/core-concepts#streams_out_of_ordering

有人可以解释我下面的语句背后的原因:

在一个主题分区,一个记录的时间戳可能不是单调与他们一起的偏移量增加。由于卡夫卡流总是会尝试处理一个主题的分区内记录跟随偏移命令,它可能会导致更大的时间戳(但规模较小的偏移量)记录进行比同一主题在较小的时间戳(但较大偏移量)记录早期处理-划分。

按我的理解,如果在一个分区的消息是由一个生产者生产的,他们的时间戳必须在非递减顺序。怎么来的邮件都无法单调递增的顺序?

apache-kafka apache-kafka-streams
1个回答
0
投票
© www.soinside.com 2019 - 2024. All rights reserved.