[jira] [Created] (KAFKA-10376) TimeWindowedDeserializer does not deserialize the end timestamp of time window aggregate message keys.

["B R (Jira)" <ji...@apache.org>]

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)