问题原因：

如下图，kafka 中配置的是监听域名的方式，但程序里使用的是 ip:port 的连接方式。

解决办法：

kafka 中配置的是域名的方式，程序里也相应配置成 域名:port 的方式（注意：本地hosts中需要做好相应的域名映射）。