admin管理员组

文章数量:1430980

The Kafka producers in my application fail to write messages to Kafka after Kafka brokers are brought down then up.

Instead, this keeps getting printed:

.springframework.kafka.core.KafkaProducerException: Failed to send; nested exception is 
.apache.kafkamon.errors.TimeoutException: Expiring 17 record(s) for test-topic-5:179287 ms has passed since batch creation

Once I restart the application, the Kafka producer is able to send messages successfully again. What is the reason send fails even though the brokers are brought back up? How do I get send to succeed without having to restart the application?

本文标签: javaKafka producers fail to send after kafka brokers are brought down then upStack Overflow