You are viewing a plain text version of this content. The canonical link for it is here.

Posted to users@kafka.apache.org by Mark Anderson <ma...@gmail.com> on 2019/03/27 22:12:16 UTC

KafkaConsumer.poll() and exceptions

Hi all

From reading the javadoc I've made the assumption that all exceptions
thrown by KafkaConsumer.poll() are unrecoverable.

What exactly does this mean with regards to the consumer instance itself?

Can it be used again in any way e.g. close then call subscribe again?

Or do you need to replace it with a new consumer instance?

Thanks
Mark