I had the same problem : Call pause() on all partitions. Then continue your loop that calls consume(), it will then poll without consuming messages.
When you want to consume again, call resume() on all partition It's not obvious at all, the doc should explain that in the documentation of method consume() and put it in red and bold. https://kafka.apache.org/090/javadoc/index.html?org/apache/kafka/clients/consumer/KafkaConsumer.html > Le 28 sept. 2016 à 06:21, Yifan Ying <nafan...@gmail.com> a écrit : > > Hi all, > > 0.10 consumers use poll() method to heartbeat Kafka brokers. Is there any > way that I can make the consumer heartbeat but not poll any messages? The > javadoc says, the recommended way is to move message processing to another > thread. But when message processing keeps failing(because a third party > service goes down for a while), the thread that actually processes messages > could have too many messages accumulated. Maybe re-sending failed messages > to another queue(IMQ) and re-processing them later is a good option? > > Thanks! > -- > Yifan
