[
https://issues.apache.org/jira/browse/KAFKA-8347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16843405#comment-16843405
]
Matthias J. Sax commented on KAFKA-8347:
----------------------------------------
I think, the cherry pick happened after RC1 was cut? Hence, fixed version
should be `2.2.2` instead of `2.2.1`? \cc [~vahid]
> Choose next record to process by timestamp
> ------------------------------------------
>
> Key: KAFKA-8347
> URL: https://issues.apache.org/jira/browse/KAFKA-8347
> Project: Kafka
> Issue Type: Improvement
> Components: streams
> Affects Versions: 2.1.0
> Reporter: Sophie Blee-Goldman
> Assignee: Sophie Blee-Goldman
> Priority: Major
> Fix For: 2.3.0, 2.1.2, 2.2.1
>
>
> Currently PartitionGroup will determine the next record to process by
> choosing the partition with the lowest stream time. However if a partition
> contains out of order data its stream time may be significantly larger than
> the timestamp of the next record. The next record should instead be chosen as
> the record with the lowest timestamp across all partitions, regardless of
> which partition it comes from or what its partition time is.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
