conduktor.io ↗

KIP-485 — Make topic optional when using through() operations in DSL

Discussion Kafka 2.6 Streams

Proposes making the intermediate repartition topic optional in Kafka Streams DSL's `through()` operation by allowing the framework to auto-infer when repartitioning is needed after a key-changing operation like `map()` before a `transform()`. Without this, calling `transform()` after a key-changing operation silently skips the necessary repartition step, producing incorrect results when downstream processing depends on key-based partitioning.

Details

AuthorLevani Kokhreidze
StatusDiscussion
Kafka Version2.6
JIRAKAFKA-8611
WikiView on Apache Wiki
Created2019-06-28
Last Modified2019-06-28
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.