Timeout of 60000ms expired before the position for partition could be determined踩坑flink消费kafka2.3.0

flink消费kafka2.3.0，时报错，分区分配的不对Kafka Client Timeout of 60000ms expired before the positionfor partition could be determined在网上找了一波，没找到原因，后面，误打误撞，发现，是因为，kafka的配置文件，server.properties,使用了主机名作为配置，在server.pr

芮呆萌061511332

8298人浏览 · 2021-07-04 19:02:46

芮呆萌061511332  ·  2021-07-04 19:02:46 发布

flink消费kafka2.3.0，时报错，分区分配的不对

Kafka Client Timeout of 60000ms expired before the position
 for partition could be determined

在网上找了一波，没找到原因，后面，误打误撞，发现，是因为，kafka的配置文件，server.properties, 使用了主机名作为配置，在server.properties中添加

host.name=192.168.0.30 （当前所在服务器的ip地址即可），每个kafka的节点都要配上相应的自己的ip地址即可

华为云开发者联盟

为开发者提供学习成长、分享交流、生态实践、资源工具等服务，帮助开发者快速成长。

加入社区

更多推荐

• · 华为云致力推进全域Serverless时代，引领技术创新，赋能行业实践
• · 基于Serverless服务构建千万车辆数据实时处理的车联网业务
• · O3使能伙伴服务作业平台维护作业专题

华为云致力推进全域Serverless时代，引领技术创新，赋能行业实践

华为云开发者联盟

基于Serverless服务构建千万车辆数据实时处理的车联网业务

华为云开发者联盟

O3使能伙伴服务作业平台维护作业专题

华为云开发者联盟

欢迎加入社区

取消 确定