Re: Reg : kafka consumer to dynamically detect topics added

2016-03-24 Thread Jason Gustafson
Hi Siddu, The consumer supports a configuration option "metadata.max.age.ms" which basically controls how often topic metadata is fetched. By default, this is set fairly high (5 minutes), which means it will take up to 5 minutes to discover new topics matching your regular expression. You can set

Reg : kafka consumer to dynamically detect topics added

2016-03-24 Thread Siddu Shebannavar
Hi Team, I'm using KafkaConsumer to consume messages from Kafka server (topics).. * It works fine for topics created before starting Consumer code... * But the problem is, it will not work if the topics created dynamically(i mean to say after consumer code started), but t