Re: Questions about Kafka 0.9 API changes

Hi Jun, ok, I created: https://issues.apache.org/jira/browse/KAFKA-1655 Greetings Valentin On Sat, 27 Sep 2014 08:31:01 -0700, Jun Rao wrote: > Valentin, > > That's a good point. We don't have this use case in mind when designing the > new consumer api. A straightforward implementation could

conflicted ephemeral node error

Hi , I am getting this error in kafka logs I wrote this conflicted ephemeral node [{"version":1,"brokerid":0,"timestamp":"1411969901501"}] at /controller a while back in a different session, hence I will backoff for this node to be deleted by Zookeeper and retry (kafka.utils.ZkUtils$) Can