Sophie Blee-Goldman created KAFKA-8347:
------------------------------------------
Summary: 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
Reporter: Sophie Blee-Goldman
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)
