Hello, I would like to start the vote on extending the TopologyDescription.Sink interface to return the class of the TopicNameExtractor in cases where dynamic routing is used.
The user can override the toString method of the TopicNameExtractor class in order to provide a better textual description if he or she chooses. https://cwiki.apache.org/confluence/display/KAFKA/KIP-321%3A+Add+method+to+get+TopicNameExtractor+in+TopologyDescription Best, Nishanth Pradeep
