您好,我在 java 线程池放入多个 kafka 生产者对象,发现当生产者发生异常后,连接池中的实例依然存在。 我想在程序中判断生产者状态是否正常,请问该怎么办呢? 环境: kafka 版本:2.3 jdk:1.8
如果你用的是官方提供的客户端,池子里的实例(长连接)会自行检测恢复的。
多谢解答
你的答案