conduktor.io ↗

KIP-463 — Auto-configure non-default Serdes passed alongside the TopologyBuilder

Discussion Streams

Fixes Kafka Streams to properly call `Serde.configure(Map<String,?> configs, boolean isKey)` on SerDes that are passed explicitly via `Consumed`, `Produced`, `Grouped`, etc., so user-provided SerDes receive the Streams application's configuration before use. The `configure()` method on explicitly-passed SerDes was either not called or called with an overwriting configuration that discarded the user's prior configuration, breaking SerDes that require application config at initialization.

Details

AuthorRichard Yu
StatusDiscussion
JIRAKAFKA-3729
WikiView on Apache Wiki
Created2019-04-26
Last Modified2019-04-26
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.