Can you provide the steps to reproduce this issue?
On Fri, Oct 24, 2014 at 6:11 PM, Bhavesh Mistry <mistry.p.bhav...@gmail.com>
wrote:
> 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
> > >
> >
>
