当前位置: 代码迷 >> 综合 >> kafka client连接远程kafka集群的配置问题
  详细解决方案

kafka client连接远程kafka集群的配置问题

热度:85   发布时间:2023-10-13 19:26:45.0

1、服务端配置

在/conf/server.propertis中添加

advertised.host.name=<远程kafka服务器的ip地址>。

我使用的kafka版本是我使用的kafka版本是kafka_2.11-1.1.0,不同的版本配置文件名称可能会不同。

如果不添加这个配置的话,客户端是连接不上服务器的,这个属性的值会被当做broker的name发布到zookeeper.虽然官方文档已经把这个属性弃用了,而是推荐使用advertised.listeners属性,但是这个属性如果配置为ip是不允许的,服务器启动会失败,具体怎么配置大家可以尝试。

kafka client连接远程kafka集群的配置问题

2、客户端配置

kafka client连接远程kafka集群的配置问题

3、单元测试创建topic

kafka client连接远程kafka集群的配置问题


  相关解决方案