[
https://issues.apache.org/jira/browse/KAFKA-8347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16842063#comment-16842063
]
Matthias J. Sax commented on KAFKA-8347:
----------------------------------------
[~ableegoldman] The "affects version" field seems not to be correct. We should
mark the first release that was affected. Hence, I think it should be `2.1` as
KIP-353 was done in this release.
> 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.3.0
> Reporter: Sophie Blee-Goldman
> Assignee: Sophie Blee-Goldman
> Priority: Major
> Fix For: 2.3.0
>
>
> 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)
