Является ли IllegalStateException: не найдена запись для подключения, которая может быть восстановлена ​​для KafkaConsumer.poll?

Question

У меня есть KafkaConsumer, где регистрируется следующая ошибка

Heartbeat thread failed due to unexpected error java.lang.IllegalStateException: No entry found for connection 1

с последующим KafkaConsumer.poll() броском IllegalStateException.

В этом случае я могу продолжать звонить на KafkaConsumer.poll(), ожидая, что он снова подключится и продолжит функционировать?

Или это неисправимая ошибка, означающая, что я больше не могу использовать этого потребителя?

Answer 1

Основной причиной этой проблемы было KAFKA-7974 , поэтому вы не должны ожидать, что восстановление будет восстановлено, поскольку внутреннее устройство потребителя должно обработать этот случай.

Это будет решено в Кафке 2.1.2, 2.2.1 и 2.3.0.