Кафка — org.apache.kafka.common.errors.NetworkException ⇐ JAVA

[Anonymous]

У меня есть клиентский код Kafka, который подключается к брокерам Kafka (сервер 0.10.1 и клиент 0.10.2). В коде есть 2 темы с 2 разными группами потребителей, а также есть производитель. Получение NetworkException из кода производителя время от времени (раз в 2 дня, раз в 5 дней,...). Мы видим информацию о (повторном) присоединении к группе потребителей в журналах для обеих групп потребителей, за которой следует исключение NetworkException из вызова производителя Future.get(). Почему мы получаем эту ошибку?
Код:

Код: Выделить всё

final Future futureResponse =
producer.send(new ProducerRecord("ping_topic", "ping"));
futureResponse.get();

Исключение:

Код: Выделить всё

org.apache.kafka.common.errors.NetworkException: The server disconnected before a response was received.
java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.NetworkException: The server disconnected before a response was received.
at org.apache.kafka.clients.producer.internals.FutureRecordMetadata.valueOrError(FutureRecordMetadata.java:70)
at org.apache.kafka.clients.producer.internals.FutureRecordMetadata.get(FutureRecordMetadata.java:57)
at org.apache.kafka.clients.producer.internals.FutureRecordMetadata.get(FutureRecordMetadata.java:25)

Определение Kafka API для NetworkException,

"При выполнении запроса произошло другое исключение IOException, связанное с сетью.
Это может быть связано с тем, что метаданные клиента устарели, и он
отправляет запрос к узлу, который уже не работает."


Подробнее здесь: https://stackoverflow.com/questions/496 ... kexception