Я использую Spring Boot и Kafka как брокер сообщений для публикации sh событий. Эти сообщения публикуются в формате asyn c с использованием шаблона Kafka. Ниже приведен фрагмент кода, который доставляет сообщение / сообщения Кафке. Теперь, если Kafka инфра-не работает, потребуется 60 секунд, чтобы сообщить приложению, что у нас 1000 запросов. Поэтому нужно сохранить какой-то механизм кэширования, чтобы увидеть, что Kafka немедленно выйдет из строя, он сохранит свое состояние в kafka и сделает все, что захочет сделать logi приложения c.
Теперь вопрос в том, есть ли хороший способ узнать, что Kafka Infra не работает, вместо того, чтобы ждать 60 секунд или какое-либо другое время конфигурации.
@Async
public void send(ProducerRecord<Key, Object> producerRecord) {
ListenableFuture<SendResult<Key, Object>> future = kafkaTemplate.send(producerRecord);
future.addCallback(sendCallback());
}
, пожалуйста, помогите мне поделиться каким-нибудь примером или подходом.