关于异步带回调函数方法的异常对象

来源：6-9 Kafka Producer集成

0x0wh04m1

2020-04-28

老师，这里我想问一下，使用异步带回调函数这种形式，如果发生异常，那么这个异常是否就是回调函数onCompletion的exception对象呢？用这种方式处理异常情况是否可行？

producer.send(record, new Callback() {
    @Override
    public void onCompletion(RecordMetadata metadata, Exception exception) {
         // TODO 处理异常情况
    }
});

写回答

1回答

Allen

2020-04-28

已采纳

这一部分大部分时候都是一些系统异常，业务异常还是建议手动处理

0x0wh04m1

非常感谢！

2020-04-28

共1条回复

Kafka多维度系统精讲，从入门到实战开发

系统讲解Kafka，实战结合，让你成为使用Kafka的高手

896 学习 · 237 问题

查看课程

相似问题

自定义partition调用异步阻塞这样的方式

回答 2

关于“提交”的概念

回答 1

同步异步发送的问题

回答 1

消费者的关闭问题

回答 1

生产者.send()和生产者.send().get()

回答 1

打开慕课网App查看更多内容