Hi,
I'm using kafka version 0.8.2.1 with old high level consumer api.
I'm following this gude:
https://cwiki.apache.org/confluence/display/KAFKA/Consumer+Group+Example
The client is working fine but after few hours of inactivity it gets
inactive and stops receiving messages.
but if I restart my client again then it starts fetching all the messages
which were not consumed during the time of it's inactivity.
Im using this configuration:
props.put("zookeeper.connect", ZOOKEEPER_HOST_ADDR);
props.put("group.id", "test");
props.put("zookeeper.session.timeout.ms","1000000");
props.put("zookeeper.sync.time.ms","20");
props.put("auto.commit.enable","true");
props.put("auto.commit.interval.ms", "100");
props.put("fetch.wait.max.ms", "100");
props.put("rebalance.backoff.ms", "20000");
can someone please help me in figuring out whats going wrong here.
--
regards,
Abhishek Chawla
