[
https://issues.apache.org/jira/browse/KAFKA-10376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
BPR updated KAFKA-10376:
------------------------
Labels: Aggregation Deserialize Key (was: Deserialize)
> Add end timestamp to Time Window key. Update TimeWindow
> Serializer/Deserializer to set end of window.
> ------------------------------------------------------------------------------------------------------
>
> Key: KAFKA-10376
> URL: https://issues.apache.org/jira/browse/KAFKA-10376
> Project: Kafka
> Issue Type: Improvement
> Components: streams
> Affects Versions: 2.6.0
> Reporter: BPR
> Priority: Major
> Labels: Aggregation, Deserialize, Key
>
> Aggregate stream consumers are not currently able to get the end timestamp
> for Time Windows from the Deserializer. This is due to the fact that the end
> timestamp is not present in the message key. The end timestamp is not
> currently added to the end of the key for Time Window aggregates.
> Update the code to add the end timestamp long onto the end of the key and
> update the Deserialized to extract and set the correct end on the Window.
> This issue is peripherally related to KAFKA-4468, KAFKA-9649 and KAFKA-10366.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
