conduktor.io ↗

KIP-837 — Allow MultiCasting a Result Record.

Accepted Kafka 3.4 Streams

Adds a `multicastTo(List<Integer> partitions)` method to `KStream` in Kafka Streams DSL that routes a single record to multiple specified partitions on the sink topic atomically. Multicasting to N partitions currently requires producing N copies of the record with a custom partitioner, wasting network and storage resources.

Details

AuthorSagar Rao
StatusAccepted
Kafka Version3.4
JIRAKAFKA-13602
WikiView on Apache Wiki
Created2022-05-08
Last Modified2022-12-21
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.