kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Maarten (JIRA)" <j...@apache.org>
Subject [jira] [Created] (KAFKA-8288) KStream.through consumer does not use custom TimestampExtractor
Date Thu, 25 Apr 2019 07:39:00 GMT
Maarten created KAFKA-8288:

             Summary: KStream.through consumer does not use custom TimestampExtractor
                 Key: KAFKA-8288
                 URL: https://issues.apache.org/jira/browse/KAFKA-8288
             Project: Kafka
          Issue Type: Bug
          Components: streams
    Affects Versions: 2.2.0
            Reporter: Maarten

The Kafka consumer created by {{KStream.through}} does not seem to be using the custom TimestampExtractor
set in Kafka Streams properties.

The documentation of {{through}} states the following

This is equivalent to calling to(someTopic, Produced.with(keySerde, valueSerde) and StreamsBuilder#stream(someTopicName,
Consumed.with(keySerde, valueSerde)).

However when I use the pattern above, the custom TimestampExtractor _is_ called.

I have verified that the streams app is reading from the specified topic and that the timestamp
extractor is called for other topics.

This message was sent by Atlassian JIRA

View raw message