kq的报错机制似乎并不完善？

[chenkaiwei]

比如kafka服务器挂掉的情形，我们调用者有办法获取到对应的错误吗？因为生产者客户端的缓冲机制，Push方法并没有真正的推送消息，所以拿不到错误，这点可以理解；但是在执行缓冲的Flush方法中，推送出错时似乎也只是打印了一下日志，并没有通过任何方式将错误传出来？所以目前kq客户端的调用者是不是完全没办法获取到Flush中的错误状态？以及后续是不是可以考虑增加一个eventBus之类的对象，以便我们调用者挂上监听获取kq的错误状态？谢谢