cloud stream 生产者异步发送消息，怎么捕获错误呢？或者怎么添加回调函数

问题遇到的现象和发生背景

cloud stream 生产者异步发送消息，怎么捕获错误呢？或者怎么添加回调函数

问题相关代码，请勿粘贴截图

运行结果及报错内容

我的解答思路和尝试过的方法

我想要达到的结果

或者你看下我的例子https://gitee.com/Huangdezhou/two

建议启动一个线程，进行单独处理。