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

Reply via email to