Re: Force producer topic metadata refresh.

2016-10-12 Thread Ismael Juma
Hi Alexandru, I think your issue will be fixed by KAFKA-4254. There's a PR available and should be merged shortly. Can you please verify? Thanks, Ismael On Wed, Oct 12, 2016 at 11:00 AM, Alexandru Ionita < alexandru.ion...@gmail.com> wrote: > OK. then my question is: why is not the producer

Re: Force producer topic metadata refresh.

2016-10-12 Thread Alexandru Ionita
OK. then my question is: why is not the producer trying to recover from this error by updating its topic metadata right away instead of waiting for the "metadata.max.age.ms" to expire? 2016-10-12 11:43 GMT+02:00 Manikumar : > we have similar setting

Re: Force producer topic metadata refresh.

2016-10-12 Thread Manikumar
we have similar setting "metadata.max.age.ms" in new producer api. Its default value is 300sec. On Wed, Oct 12, 2016 at 3:04 PM, Alexandru Ionita < alexandru.ion...@gmail.com> wrote: > Hello kafka users!! > > I'm trying implement/use a mechanism to make a Kafka producer imperatively > update its

Force producer topic metadata refresh.

2016-10-12 Thread Alexandru Ionita
Hello kafka users!! I'm trying implement/use a mechanism to make a Kafka producer imperatively update its topic metadata for a particular topic. Here is the use case: we are adding partitions on topics programmatically because we want to very strictly control how messages are published to