KIP-307 — Allow to define custom processor names with KStreams DSL
Accepted Kafka 2.3 Streams
Adds a `NamedOperation` interface with an `as(String)` factory on the Kafka Streams DSL control classes (`Produced`, `Consumed`, `Printed`, `Joined`, `Grouped`, `Suppressed`) plus overloads on the stateless operators, so every processor in a topology can be given a custom name. Processor names are otherwise generated from the operation type with a uniqueness suffix (`KSTREAM-MAP-0000000000`), which makes the `Topology#describe()` lineage of a topology with dozens of operations hard to read.
Details
| Author | Florian Hussonnois |
| Status | Accepted |
| Kafka Version | 2.3 |
| JIRA | KAFKA-6958 |
| Wiki | View on Apache Wiki |
| Created | 2018-05-27 |
| Last Modified | 2019-05-15 |
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.