Hi guys,

I was wondering what the plan in 0.9, was for the topic filters that are
today in the High level consumer. The new API'
<http://people.apache.org/~nehanarkhede/kafka-0.9-consumer-javadoc/doc/org/apache/kafka/clients/consumer/KafkaConsumer.html>s
subscribe methods, seem to be working with real topic names (which I
personally like).

Given, the topic filters today support automatic topic discovery (e.g.:
MirrorMaker), would there be another mechanism to notify consumers of new
topics and change in partitions? (I was thinking about an internal topic
that provided these system changes, that consumers can listen to and choose
whether or not they want to subscribe to say a newly created topic).

Thanks
Vinoth

Reply via email to