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

夏天 发表于: 2020-11-06   最后更新时间: 2020-11-06  

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

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

环境:

  • kafka 版本:2.3
  • jdk:1.8


您需要解锁本帖隐藏内容请: 点击这里
本帖隐藏的内容




上一条: kafka 发送 较大文件时速度慢怎么办?
下一条: 程序发布到websphere报错,java.lang.IllegalArgumentException: Could not find a 'KafkaClient' entry in the JAAS configuration.

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