为何Upsolver Kafka数据源尝试连接未配置的Broker节点node6?
Kafka连接超时并尝试访问未指定Broker的原因
- Kafka集群的工作机制是:客户端(此处为Upsolver)通过初始指定的Broker节点(
node1-node5)连接集群后,会从这些节点获取整个集群的完整Broker列表,后续客户端会直接与负责目标数据分区的Leader Broker建立连接,而非一直依赖初始指定的节点。 - 当你要摄取的Kafka Topic中,存在某个分区的Leader Broker是
node6时,Upsolver会自动尝试连接node6来拉取该分区的数据——这是Kafka客户端的正常优化行为,目的是直接从数据的源头节点获取数据,提升摄取效率。 - 出现超时异常的核心原因是:Upsolver所在的网络环境未开放对
node6的访问权限(比如防火墙、安全组规则限制),导致无法建立连接。
内容的提问来源于stack exchange,提问作者Ajay C
相关产品推荐
相关产品推荐

