broker端listeners配置成用户名不用ip,那用springboot时bootstrap-servers: 这一属性该如何设置?

胡Ba一.ˇ° 发表于: 2018-11-29   最后更新时间: 2018-11-30 10:00:33   6,709 游览

首先感谢大佬回答问题,很感动啊我看问答区的问题大佬基本上都一一回答了!真的感谢。

问题描述:

broker端配置是这样listeners=PLAINTEXT://kafka2:9092,这里用的是用户名没用ip进行绑定但是测过映射成功,绑定成功

springboot kafka配置文件中

spring:
   kafka:
      bootstrap-servers: 188.88.888.888:9092

然后启动项目会报错如下:

rg.springframework.context.ApplicationContextException: Failed to start bean 'org.springframework.kafka.config.internalKafkaListenerEndpointRegistry'; nested exception is org.apache.kafka.common.errors.TimeoutException: Timeout expired while fetching topic metadata

说获取主题元数据时超时过期,是我那个地方ip绑定的问题么?难道bootstrap-servers这一属性我也写成:kafka2:9092 嘛?

发表于 2018-11-29

嗯,也要写成kafka2,你做个host可以先试下。

必须要在Windows上配置host映射之后才能连上吗?

现在错误变了..麻烦看下  我搭了一个kafka集群
 bootstrap-servers: 188.88.888.888:9092  这样配置启动服务后报错为:
Can't resolve address: kafka1:9092
Can't resolve address: kafka2:9092
Can't resolve address: kafka3:9092
三个错误循环报错 一直说无法解析 ,必须要现在连接broker的机器上先配置和映射才可以连接嘛?这样子好麻烦...那还不如我broker配置的时候就绑定ip不绑定用户名.我绑定用户名是因为书上说尽量绑定用户名,绑定ip不好

嗯 因为你的域名节点获取后解析不了。所以要先配置host。

好的好的..那我还是换成绑定ip的吧...谢谢回答

你的答案

查看kafka相关的其他问题或提一个您自己的问题