kafka 怎么在生产者发送数据之前,使用Java代码检测网络状态、检测kafka集群运行状态呢 目前做生产测试,由于正式环境下,数据是通过读取文件,所以想要在生产者发送数据之前检测一下网络状态和kafka集群的运行状态 kafka 2.3 jdk1.8 kafka集群3个节点
如果你用官方的客户端的话,kafka连接池会默认检测心跳,等重连机制的,你用关注这些的。
你的答案