kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Florian Hussonnois (JIRA)" <j...@apache.org>
Subject [jira] [Created] (KAFKA-6958) Allow to define custom processor names with KStreams DSL
Date Sun, 27 May 2018 20:08:00 GMT
Florian Hussonnois created KAFKA-6958:
-----------------------------------------

             Summary: Allow to define custom processor names with KStreams DSL
                 Key: KAFKA-6958
                 URL: https://issues.apache.org/jira/browse/KAFKA-6958
             Project: Kafka
          Issue Type: Improvement
          Components: streams
    Affects Versions: 1.1.0
            Reporter: Florian Hussonnois


Currently, while building a new Topology through the KStreams DSL the processors are automatically
named.

The genarated names are prefixed depending of the operation (i.e KSTREAM-SOURCE, KSTREAM-FILTER,
KSTREAM-MAP, etc).

To debug/understand a topology it is possible to display the processor lineage with the method
Topology#describe(). However, a complex topology with dozens of operations can be hard to
understand if the processor names are not relevant.

It would be useful to be able to set more meaningful names. For example, a processor name
could describe the business rule performed by a map() operation.

[KIP-307|https://cwiki.apache.org/confluence/display/KAFKA/KIP-307%3A+Allow+to+define+custom+processor+names+with+KStreams+DSL]



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Mime
View raw message