Всем привет, использую kafkatemplate как клиент, когда вызываю его send()

Question

Всем привет, использую kafkatemplate как клиент, когда вызываю его send()

метод, данные уходят в топик. Бывает случаи когда происходит NetworkException или TimeoutException. Чтобы обработать исключение попытался делать так:
try{
ListenableFuture<SendResult<String, String>> future = kafkaTemplate.send(foo_topic, bar_json);
SendResult<String, String> result = future.get();
} catch(Exception ex){
System.out.println(1);
}
Но, никак не поймаю исключение, что посоветуете, как обработать исключение?

#kafka #russian #software

0

02.12.2021

1 ответов

15 просмотров

Вячеслав . · Accepted Answer

Вячеслав .

ListenableFuture.addCallback(SuccessCallback<? super T> var1, FailureCallback var2) и заимплементить FailureCallbackh

0

02.12.2021

52 похожих чатов

Всем привет, использую kafkatemplate как клиент, когда вызываю его send()

1 ответов

Похожие вопросы