conduktor.io ↗

KIP-321 — Update TopologyDescription to better represent Source and Sink Nodes

Accepted Kafka 2.1 Streams

Updates `TopologyDescription` to expose `SourceNode` and `SinkNode` as typed objects with structured accessors (topics, pattern, etc.) instead of returning string representations only. Users who want to perform runtime introspection on topology source/sink nodes are forced to parse `toString()` output, which is brittle and not part of the stable API contract.

Details

AuthorNishanth Pradeep
StatusAccepted
Kafka Version2.1
JIRAKAFKA-6966
WikiView on Apache Wiki
Created2018-06-20
Last Modified2018-08-09
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.