conduktor.io ↗

KIP-120 — Cleanup Kafka Streams builder API

Accepted Kafka 1.0 Streams

Deprecates TopologyBuilder and KStreamBuilder and replaces them with Topology and StreamsBuilder in the org.apache.kafka.streams package, and adds a TopologyDescription interface for inspecting the processor graph. The old classes leaked internal DSL methods on the processor API builder and mixed DSL and PAPI abstractions, making the public API inconsistent and hard to evolve.

Details

AuthorMatthias J. Sax
StatusAccepted
Kafka Version1.0
JIRAKAFKA-3856
WikiView on Apache Wiki
Created2017-02-03
Last Modified2017-09-08
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.