Think, new versions have better ways of doing this. In 0.10.2, because poll() ensure liveness, you can disable auto commits and use consumer pause() to avoid calling poll() (so brokers may ignore max.poll.interval.ms) so those partitions are not assigned to other consumers and also handle ConsumerRebalanceListener onPartitionsAssigned or reduce amount of data being processed using max.poll.records. https://kafka.apache.org/0102/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html
On Thu, Jan 25, 2018 at 1:27 AM, Sameer Kumar <sam.kum.w...@gmail.com> wrote: > I have a scneario, let say due to GC or any other issue, my consumer takes > longer than max.poll.interval.ms to process data, what is the alternative > for preventing the consumer to be marked dead and not shun it out of the > consumer group. > > Though the consumer has not died and session.timeout.ms is being sent at > regular intervals in this case. > > -Sameer. > -- Radha Krishna, Proddaturi 253-234-5657
