我正在给Kafka发信息。
每当我在onsuccess()方法中出现异常或在onsuccess()中调用methhods时,应用程序不会显示任何错误消息。如何解决这个问题?
我在用@restcontroller注解的类中调用sendmessagetokafka。
在我的例子中
1/0不会在运行时抛出算术异常:/by 0
我的存储库也有错误,但这个错误不是在onsuccess()方法中抛出的?
public void sendMessageToKafka(List<String> messageList) {
for ( String message : messageList)
{
ListenableFuture<SendResult<String,String>> future = kafkaTemplate.send(topicName, message);
future.addCallback(new ListenableFutureCallback<SendResult<String, String>>() {
@Override
public void onSuccess(SendResult<String, String> result) {
System.out.println("Sent message=[" + message + "] with offset=[" + result.getRecordMetadata().offset()
+ "]" );
// if i add error below my application doest crash or throw error
int num =1/0
myRepository.saveInDb(message);
}
@Override
public void onFailure(Throwable ex) {
System.out.println("Unable to send message=[" + message + "] due to : " + ex.getMessage());
myRepository.saveInDb(message);
}
});
暂无答案!
目前还没有任何答案,快来回答吧!