如何解决Kafka无法远程连接且Kafka Operator中无法配置advertise listener的问题

以下是不同主流Kafka Operator场景下的配置方案：

Strimzi 开源Kafka Operator（最常用版本） #

• 直接编辑你的Kafka自定义资源(CR)文件，在spec.kafka.config字段下添加advertised.listeners配置即可，Operator会自动将配置同步到所有broker的server.properties文件中，示例配置片段如下：

apiVersion: kafka.strimzi.io/v1beta2
kind: Kafka
metadata:
  name: my-kafka-cluster
spec:
  kafka:
    config:
      # 替换为客户端实际可访问的公网IP/域名和对应端口
      advertised.listeners: PLAINTEXT://<你的公网访问地址>:9092,SSL://<你的公网访问地址>:9093
    # 如果你是通过NodePort/LoadBalancer方式暴露外部访问，也可以在listener配置中单独指定每个broker的advertised地址
    listeners:
      - name: external
        port: 9094
        type: nodeport
        tls: false
        configuration:
          brokers:
            - broker: 0
              advertisedHost: <broker0公网IP>
              advertisedPort: <broker0对应的NodePort端口>
            - broker: 1
              advertisedHost: <broker1公网IP>
              advertisedPort: <broker1对应的NodePort端口>

• 修改完成后执行kubectl apply -f <你的kafka CR文件名>，等待Operator自动滚动更新Kafka集群，更新完成后可进入broker容器查看/etc/kafka/server.properties确认配置已生效。

Confluent 官方Kafka Operator #

• 编辑Kafka自定义资源文件，在spec.kafka.configOverrides.server字段下添加advertised.listeners配置即可，示例配置片段如下：

apiVersion: platform.confluent.io/v1beta1
kind: Kafka
metadata:
  name: kafka
  namespace: confluent
spec:
  kafka:
    configOverrides:
      server:
        - advertised.listeners=PLAINTEXT://<公网访问地址>:9092

• apply配置后等待集群滚动更新完成即可。

其他小众Kafka Operator #

• 几乎所有规范实现的Kafka Operator都支持通过CR的自定义配置字段注入server.properties参数，找到对应CR的配置入口直接添加advertised.listeners即可，无需手动修改容器或宿主机上的配置文件。
• 如果确认Operator未暴露相关配置入口，可通过给Kafka broker容器挂载自定义ConfigMap的方式覆盖server.properties，注意要将原有默认配置和新增的advertised.listeners参数合并后再挂载，避免丢失核心配置导致集群异常。

注意事项 #

• 配置的advertised.listeners地址必须是客户端实际可以访问到的公网IP/域名，不能填集群内部的Service域名或私有IP。
• 注意参数正确拼写为advertised.listeners，不要漏写末尾的s和中间的d。
• 配置对应的端口要和你对外暴露的访问端口一致，提前放通对应端口的防火墙、安全组规则。

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