Производители Kafka не могут отправить товар после того, как брокеры Kafka были уволены, а затем поднялись ⇐ JAVA

[Anonymous]

Производители Kafka в моем приложении не могут писать сообщения Kafka после того, как брокеры Kafka отключаются, а затем поднимаются.
Вместо этого продолжает печататься следующее:

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

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

После перезапуска приложения производитель Kafka снова сможет успешно отправлять сообщения. В чем причина сбоя отправки, хотя брокеры снова активизировались? Как добиться успешной отправки без перезапуска приложения?

Подробнее здесь: https://stackoverflow.com/questions/792 ... wn-then-up