我最近碰到这篇文章上的Apache卡夫卡文档随同关于乱序消息的处理卡夫卡流
https://kafka.apache.org/21/documentation/streams/core-concepts#streams_out_of_ordering
有人可以解释我下面的语句背后的原因:
在一个主题分区,一个记录的时间戳可能不是单调与他们一起的偏移量增加。由于卡夫卡流总是会尝试处理一个主题的分区内记录跟随偏移命令,它可能会导致更大的时间戳(但规模较小的偏移量)记录进行比同一主题在较小的时间戳(但较大偏移量)记录早期处理-划分。
按我的理解,如果在一个分区的消息是由一个生产者生产的,他们的时间戳必须在非递减顺序。怎么来的邮件都无法单调递增的顺序?
当它产生消息A卡夫卡生产者可以指定时间戳。
与标准的Java API制作的例子:https://kafka.apache.org/21/javadoc/org/apache/kafka/clients/producer/ProducerRecord.html#ProducerRecord-java.lang.String-java.lang.Integer-java.lang.Long-K-V-