I am using one from the Kafka Trunk branch.
Thanks,
Bhavesh
On Fri, Oct 24, 2014 at 5:24 PM, Neha Narkhede <neha.narkh...@gmail.com>
wrote:
> 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
> >
>
