Matthias J. Sax created KAFKA-8958: -------------------------------------- Summary: Fix Kafka Streams JavaDocs with regard to used Serdes Key: KAFKA-8958 URL: https://issues.apache.org/jira/browse/KAFKA-8958 Project: Kafka Issue Type: Improvement Components: streams Reporter: Matthias J. Sax
In older released, Kafka Streams applied operator specific overwrites of Serdes as in-place overwrites. In newer releases, Kafka Streams tries to re-use Serdes more "aggressively" by pushing serde information downstream if the key and/or value did not change. However, we never updated the JavaDocs accordingly. For example `KStream#through(String topic)` JavaDocs say: {code:java} Materialize this stream to a topic and creates a new {@code KStream} from the topic using default serializers, deserializers, and producer's {@link DefaultPartitioner}. {code} The JavaDocs don't put into account that Serdes might have been set further upstream, and the defaults from the config would not be used. `KStream#through()` is just one example. We should address this through all JavaDocs over all operators (ie, KStream, KGroupedStream, TimeWindowedKStream, SessionWindowedKStream, KTable, and KGroupedTable. -- This message was sent by Atlassian Jira (v8.3.4#803005)