[
https://issues.apache.org/jira/browse/KAFKA-8347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-8347:
---------------------------------------
Fix Version/s: (was: 2.2.1)
2.2.2
> 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.2
>
>
> 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)
