Which version of Kafka are you using on the consumer?
On Fri, Oct 24, 2014 at 4:14 PM, Bhavesh Mistry <mistry.p.bhav...@gmail.com>
wrote:
> HI Kafka Community ,
>
> I am using kafka trunk source code and I get following exception. What
> could cause the iterator to have FAILED state. Please let me know how I
> can fix this issue.
>
>
>
>
>
> *java.lang.IllegalStateException: Iterator is in failed state at
> kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:54)*
> Here is Properties:
>
> Properties props = new Properties();
> props.put("zookeeper.connect", zkConnect);
> props.put("group.id", groupId);
> * props.put("consumer.timeout.ms <http://consumer.timeout.ms>",
> "-1");*
> props.put("zookeeper.session.timeout.ms", "10000");
> props.put("zookeeper.sync.time.ms", "6000");
> props.put("auto.commit.interval.ms", "2000");
> props.put("rebalance.max.retries", "8");
> props.put("auto.offset.reset", "largest");
> props.put("fetch.message.max.bytes","2097152");
> props.put("socket.receive.buffer.bytes","2097152");
> props.put("auto.commit.enable","true");
>
>
> Thanks,
>
> Bhavesh
>
