Hi, I don't seem to find response to John's comment : http://search-hadoop.com/m/Kafka/uyzND11alrn1G5N3Y1?subj=Re+Discuss+KIP+321+Add+method+to+get+TopicNameExtractor+in+TopologyDescription
On Tue, Jul 3, 2018 at 7:38 PM, Nishanth Pradeep <nishanth...@gmail.com> wrote: > 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 >
