conduktor.io ↗

KIP-307 — Allow to define custom processor names with KStreams DSL

Discussion Kafka 2.3 Admin

Tracks the implementation status of named operations in Kafka Streams DSL introduced in KIP-307, including the `NamedOperation` interface and `as(String)` factory methods on `Produced`, `Consumed`, `Joined`, `Grouped`, and `Suppressed`. Without named operations, processor topology node names are auto-generated as opaque identifiers, making it difficult to correlate application logic with topology diagrams and metrics.

Details

AuthorJohn Roesler
StatusDiscussion
Kafka Version2.3
WikiView on Apache Wiki
Created2019-05-01
Last Modified2019-05-01
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.