[
https://issues.apache.org/jira/browse/KAFKA-10376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
BPR updated KAFKA-10376:
------------------------
Description:
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:
When a _Consumer_ is consuming messages containing Time Windowed aggregates, it
has no way of obtaining the _end_ timestamps of the window contained in the
key; instead, it must specify the window size (which it likely does not know)
or receive end timestamps set to Long.MAX_VALUE. -- thus, rendering the window
essentially unbound. An objective Consumer should not be expected to know the
window size of the aggregate messages it is consuming. This is especially true
if it is consuming several different topics with windows off varying size.
This issue is peripherally related to KAFKA-4468, KAFKA-9649 and KAFKA-10366.
Issue Type: Improvement (was: Bug)
Summary: Add end timestamp to Time Window key. Update TimeWindow
Serializer/Deserializer to set end of window. (was: TimeWindowedDeserializer
does not deserialize the end timestamp of time window aggregate message keys.)
> 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
>
> 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)
