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

Extend `TopologyDescription.Sink` to return `TopicNameExtractor`

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 2.0.0
    • Fix Version/s: 2.1.0
    • Component/s: streams
    • Labels:

      Description

      With KIP-303, a dynamic routing feature was added and `TopologyDescription.Sink#topic()` returns `null` if this feature is used.

      It would be useful to get the actually used `TopicNameExtractor` class from the `TopologyDescription`.

      We suggest to add `Class<? extends TopicNameExtractor> TopologyDescription.Sink#topicNameExtractor()` and let it return `null` if dynamic routing feature is not used.

      KIP-321: https://cwiki.apache.org/confluence/display/KAFKA/KIP-321%3A+Update+TopologyDescription+to+better+represent+Source+and+Sink+Nodes

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                nprad Nishanth Pradeep
                Reporter:
                mjsax Matthias J. Sax
              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: