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
| Author | Aishwarya Pradeep Kumar |
| Status | Accepted |
| Kafka Version | 2.5 |
| JIRA | KAFKA-7658 |
| Wiki | View on Apache Wiki |
| Created | 2019-09-12 |
| Last Modified | 2020-02-11 |
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.