Kafka Producer не повторяет попытку в приложении Spring Boot ⇐ JAVA

[Гость]

Я пытаюсь проверить свойство исключения повторной попытки Kafka Producer в случае временной ошибки. Но это не повторная попытка. Я где-то читал, что конфигурация ProducerConfig.RETRIES_CONFIG в Kafka работает независимо от того, ловите вы исключения или нет. Так что я не понимаю, почему он не повторяет попытку?
@Bean
public Map producerConfigs() {
Map props = new HashMap();
props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, bootStrapServers);
props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
//Records will be failed if they can’t be delivered in delivery.timeout.ms
props.put(ProducerConfig.DELIVERY_TIMEOUT_MS_CONFIG,"120000");
// Only retry after one second.
props.put(ProducerConfig.RETRY_BACKOFF_MS_CONFIG, "1000");
// Set the number of retries
props.put(ProducerConfig.RETRIES_CONFIG, "3");
return props;
}

public void pushMessageToKafka(Product product) {

try {
String payload= objectMapper.writeValueAsString(product);

if(!checkIfTopicExists("product-unknown-kafka-topic")) {
throw new TimeoutException("Failed to send message to Kafka topic" );
}

ProducerRecord producerRecord = new ProducerRecord(productTopic,
null, product.getProductName(), payload);

ListenableFuture future = kafkaTemplate.send(producerRecord);
future.addCallback(new KafkaSendCallback() {

@Override
public void onFailure(KafkaProducerException ex) {
log.error("Failed to send product to kafka for productName:{}", product.getProductName());

}

@Override
public void onSuccess(SendResult result) {
String topic = result.getProducerRecord().topic();
log.info("Sucsessfully send product details to kafka for productName:{} topic:{}", product.getProductName(),topic);
}

});

} catch (Exception e) {
log.error("Exception occured while trying to send product to kafka for productName:{} error:{}",
product.getProductName(), e.getMessage());

}

}


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