Re: KafkaConsumer pause method not working as expected

You should use ConsumerRebalanceListener to check if there is a rebalance or not. Seeing same assigned partitions after each poll doesn't mean there is no rebalance. Steve On Wed, Aug 1, 2018, 8:57 AM Manoj Khangaonkar wrote: > Hi, > > I am implementing flow control by > > (1) using the pause(

KafkaConsumer pause method not working as expected

Hi, I am implementing flow control by (1) using the pause(partitions) method on the consumer to stop consumer.poll from returning messages. (2) using the resume(partitions) method on the consumer to let consumer.poll return messages This works well for a while. Several sets of pause-resume wor