工作中用java代码连接k8s集群中的kafka集群时消费者java代码一直报异常marking the coordinator (id rack null) dead for group。经过长时间试错,有两点解决办法。
首先,更新pom文件中的kafka-clients版本,我之前用的0.11.0.0版本已经无法完美支持新版本的kafka了,所以改成新版我改为了:2.4.1
第二就是通过idea工具找到该方法,打断点:
在画圈处打断点,发现解析出来的host域名不是在application.yml中配置的域名,在本机的hosts文件改为你debug出来的映射即可。