Hello Everyone, I have created a new KIP to discuss extending TopologyDescription. You can find it here:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-321%3A+Add+method+to+get+TopicNameExtractor+in+TopologyDescription Please provide any feedback that you might have. Best, Nishanth Pradeep