conduktor.io ↗

KIP-182 — Reduce Streams DSL overloads and allow easier use of custom storage engines

Accepted Kafka 1.0 Streams

KIP-182 reduces the KafkaStreams DSL API surface by replacing many overloaded per-parameter methods with a small set of parameter-object overloads using `Produced`, `Consumed`, `Serialized`, `Joined`, and `Materialized` config objects. The explosion of method overloads (e.g. 8 for `KStream.print()`) made the DSL hard to navigate in IDEs and made it difficult to add per-operator state-store options without adding yet more overloads.

Details

AuthorDamian Guy
StatusAccepted
Kafka Version1.0
JIRAKAFKA-5651
WikiView on Apache Wiki
Created2017-07-26
Last Modified2018-12-12
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.