Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-6958

Allow to define custom processor names with KStreams DSL

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Resolved
    • Minor
    • Resolution: Fixed
    • 1.1.0
    • 2.4.0
    • streams

    Description

      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

      Attachments

        Activity

          People

            fhussonnois Florian Hussonnois
            fhussonnois Florian Hussonnois
            Votes:
            1 Vote for this issue
            Watchers:
            6 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: