kafka生产者回调不抛出错误

monwx1rj  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(164)

我正在给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);
            }
        });

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题