[
https://issues.apache.org/jira/browse/KAFKA-10376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
BPR updated KAFKA-10376:
------------------------
Description:
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.
was:
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.
> 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: Deserialize
>
> 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)
