B R created KAFKA-10376:
---------------------------
Summary: TimeWindowedDeserializer does not deserialize the end
timestamp of time window aggregate message keys.
Key: KAFKA-10376
URL: https://issues.apache.org/jira/browse/KAFKA-10376
Project: Kafka
Issue Type: Bug
Components: streams
Affects Versions: 2.6.0
Reporter: B R
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.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
