Hi

Reviewing the javadoc for KafkaConsumer.poll() I'd like to confirm the
status of the consumer after the poll method throws an exception.
I assume for an unrecoverable KafkaException you could not re-use the
consumer and would need to create a brand new KafkaConsumer object?

Are there any cases where it would be OK to re-use the KafkaConsumer after
poll() throws an exception?

Thanks,
Mark

Reply via email to