如何查看 kafka 生产者是否正常?

夏天 发表于: 2020-11-06   最后更新时间: 2020-11-06 17:22:36   2,175 游览

您好,我在 java 线程池放入多个 kafka 生产者对象,发现当生产者发生异常后,连接池中的实例依然存在。

我想在程序中判断生产者状态是否正常,请问该怎么办呢?

环境:

  • kafka 版本:2.3
  • jdk:1.8
发表于 2020-11-06

如果你用的是官方提供的客户端,池子里的实例(长连接)会自行检测恢复的。

夏天 -> 半兽人 4年前

多谢解答

你的答案

查看kafka相关的其他问题或提一个您自己的问题