栏目分类:
子分类:
返回
终身学习网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
终身学习网 > IT > 软件开发 > 后端开发 > Java

Kafka 客户端请求地址的网络问题排查解决

Java 更新时间:发布时间: 百科书网 趣学号
问题:
    filebeat 与 Kafka(9台) 由于网络限制原因,申请开通了 filebeat 连通 kafka 网络2个(broker8,broker9),出现上传日志的连接问题,详细见[Kafka-客户端请求地址策略-0-filebeat连接Kafka配置信息.png、 Kafka-客户端请求地址策略-1-filebeat连接失败日志.png]。
Kafka-客户端请求地址策略-0-filebeat连接Kafka配置信息.png

Kafka-客户端请求地址策略-1-filebeat连接失败日志.png

 分析:

    从 filebeat 连接日志可以看出虽然配置仅设置连接 broker8,broker9,filebeat 日志中出现 filebeat 连接 broker6,broker7 的错误日志,说明 Kafka 客户端会根据 metadata 信息自动连接到 Kafka 集群该 Topic 主分区 Partition。见[Kafka-客户端请求地址策略-2-介入前主分区信息.png、Kafka-客户端请求地址策略-3-介入前Broker分区信息.png]。
Kafka-客户端请求地址策略-2-介入前主分区信息.png

Kafka-客户端请求地址策略-3-介入前Broker分区信息.png

 
解决:

方案1:
    申请 filebeat 连接 kafka 所有 Broker 的网络连通权限。

方案2(临时):
    通过 KafkaManager UI界面手动把所有分区移到 broker8,broker9 上面,经测试 filebeat 上传日志正常。见[Kafka-客户端请求地址策略-4-介入后主分区信息.png、 Kafka-客户端请求地址策略-5-介入后Broker分区信息.png]。

Kafka-客户端请求地址策略-4-介入后主分区信息.png

Kafka-客户端请求地址策略-5-介入后Broker分区信息.png

转载请注明:文章转载自 www.051e.com
本文地址:http://www.051e.com/it/274931.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 ©2023-2025 051e.com

ICP备案号:京ICP备12030808号