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
| Author | Levani Kokhreidze |
| Status | Discussion |
| Kafka Version | 2.6 |
| JIRA | KAFKA-8611 |
| Wiki | View on Apache Wiki |
| Created | 2019-06-28 |
| Last Modified | 2019-06-28 |
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.