High Level Consumer Iterator IllegalStateException Issue

[Bhavesh Mistry]

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