Kubernetes环境下跨Elasticsearch集群连接失败问题排查求助

我来帮你梳理下这个跨集群连接的问题，结合你给出的配置和现象，咱们一步步拆解：

核心问题定位：Sniff模式的端口误用 #

你配置cluster_two用了sniff模式，指定的seeds是122.22.222.182:30005，但这个端口是K8s里elasticsearch-client服务映射的HTTP端口（9200），而Sniff模式需要使用Elasticsearch的传输层端口（默认9300）——因为sniff是通过ES的集群发现协议自动获取节点列表，走的是TCP传输层，不是HTTP协议。

你用curl能访问30005端口正常，是因为curl走的是HTTP协议，但ES的跨集群sniff模式需要和目标集群的节点传输层通信，而你的elasticsearch-discovery服务是ClusterIP类型，9300端口只在K8s集群内部可访问，外部的ES集群根本连不上这个端口，这就是为什么会出现超时错误。

两种可行的解决方案 #

方案一：改用Proxy模式连接cluster_two #

Proxy模式是通过HTTP端口转发跨集群请求，正好匹配你已经暴露的30005端口。修改你的远程集群配置如下：

{
  "persistent" : {
    "cluster" : {
      "remote" : {
        // 保留其他集群配置...
        "cluster_two" : {
          "mode" : "proxy",
          "proxy_address" : "122.22.222.182:30005",
          "skip_unavailable" : "false",
          "transport" : {
            "compress" : "true"
          }
        }
      }
    }
  }
}

执行以下命令更新集群设置：

PUT _cluster/settings

之后可以用这个命令测试连接：

GET /_remote/cluster_two/_cluster/health

方案二：暴露9300端口并使用Sniff模式 #

如果你坚持要用Sniff模式，需要把目标集群的传输层端口（9300）暴露为NodePort：

1. 修改K8s中elasticsearch-discovery服务的配置，改为NodePort类型：

apiVersion: v1
kind: Service
metadata:
  name: elasticsearch-discovery
spec:
  type: NodePort
  ports:
  - port: 9300
    targetPort: 9300
    nodePort: 30006 # 选择一个K8s集群中可用的NodePort
  selector:
    # 替换为你的ES节点对应的标签，比如 app=elasticsearch, role=data/master
    app: elasticsearch
    role: data

2. 更新远程集群配置的seeds为新暴露的NodePort：

"cluster_two" : {
  "mode" : "sniff",
  "skip_unavailable" : "false",
  "transport" : {
    "compress" : "true"
  },
  "seeds" : [ "122.22.222.182:30006" ]
}

3. 先验证端口连通性，在源ES集群所在虚拟机执行：

nc -zv 122.222.182.182 30006

确保能正常连通后，再更新集群设置并测试跨集群查询。

额外排查点 #

• 版本兼容性：确认源ES集群的版本和cluster_two的7.10.2是否兼容（7.x内部跨小版本没问题，跨大版本比如6.x和7.x可能存在兼容性问题）
• 网络策略：如果K8s集群启用了网络策略，要确保源集群所在的虚拟机能访问目标集群的对应端口（30005或30006）
• 集群名称：虽然跨集群允许同名，但如果两个集群的cluster.name完全一致，可能会引发一些异常，建议确认并保持不同

内容的提问来源于stack exchange，提问作者NoamiA