conduktor.io ↗

KIP-523 — Add KStream#toTable to the Streams DSL

Accepted Kafka 2.5 Streams

Adds a KStream#toTable() method to the Streams DSL that converts an event stream into a KTable (changelog stream) without consuming from the beginning of the topic. This enables users who cannot replay from offset 0 — e.g., due to data size or retention — to materialize a table from a running stream.

Details

AuthorAishwarya Pradeep Kumar
StatusAccepted
Kafka Version2.5
JIRAKAFKA-7658
WikiView on Apache Wiki
Created2019-09-12
Last Modified2020-02-11
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.