Могу ли я игнорировать org.apache.kafka.common.errors.NotLeaderForPartitionExceptions?

Question

продюсер Мои Apache Кафка (0.9.0.1) периодически бросает

org.apache.kafka.common.errors.NotLeaderForPartitionException 

Мой код, который выполняет Кафка отправить это напоминает

final Future<RecordMetadata> futureRecordMetadata = KAFKA_PRODUCER.send(new ProducerRecord<String, String>(kafkaTopic, UUID.randomUUID().toString(), jsonMessage)); 

try { 
    futureRecordMetadata.get(); 
} catch (final InterruptedException interruptedException) { 
    interruptedException.printStackTrace(); 
    throw new RuntimeException("sendKafkaMessage(): Failed due to InterruptedException(): " + sourceTableName + " " + interruptedException.getMessage()); 
} catch (final ExecutionException executionException) { 
    executionException.printStackTrace(); 
    throw new RuntimeException("sendKafkaMessage(): Failed due to ExecutionException(): " + sourceTableName + " " + executionException.getMessage()); 
} 

Ловлю NotLeaderForPartitionException внутри catch (final ExecutionException executionException) {} блока.

Можно ли игнорировать это конкретное исключение?

Получено ли мое сообщение Kafka успешно?

Answer 1

Я новичок в Kafka, но из моего понимания, если вы получили NotLeaderForPartitionException, ваши данные были не написан успешно.

Каждая тема обслуживается одним или несколькими брокерами (с одним лидером, остальные брокеры называются последователями). Производителю необходимо отправлять новые сообщения ведущему брокеру (который внутренне реплицирует данные всем подписчикам).

Я предполагаю, что ваш клиент-производитель не подключается к правильному Брокеру, то есть к подписчику вместо лидера, и этот последователь отклоняет ваш запрос на отправку.