Bitnami Kafka是否支持OpenShift Routes？外部访问问题咨询

Bitnami Kafka确实不像Strimzi/AMQ Streams那样内置OpenShift Route集成，得手动调整监听配置+适配Route规则，以下是具体步骤：

1. 修正Kafka Broker的监听与公告地址 #

Bitnami Kafka的对外访问核心是让Broker正确公告外部可访问的地址，通过Helm values或环境变量调整：

• 若用Helm部署，修改values.yaml：

  kafka:
    listeners:
      plaintext:
        enabled: true # 保留集群内部通信端口
      external:
        enabled: true
        type: ssl # 推荐用SSL，适配OpenShift Route的TLS终止
        port: 9094
        advertisedHost: "kafka-external.apps.your-cluster.com" # 填你要用来访问的Route域名
        advertisedPort: 443 # Route默认HTTPS端口
  

• 直接改StatefulSet的话，设置环境变量：

  KAFKA_LISTENERS=PLAINTEXT://:9092,SSL://:9094
  KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://kafka-headless:9092,SSL://kafka-external.apps.your-cluster.com:443
  

  更新StatefulSet后，重启所有Broker pod生效。

2. 创建适配的OpenShift Route #

因为Kafka用SSL监听，Route用边缘终止（Edge Termination）处理外部TLS，转发到Broker的SSL端口：

• 编写Route YAML（kafka-external-route.yaml）：

  apiVersion: route.openshift.io/v1
  kind: Route
  metadata:
    name: kafka-external
    namespace: your-kafka-namespace
  spec:
    host: kafka-external.apps.your-cluster.com
    to:
      kind: Service
      name: kafka
    port:
      targetPort: external-ssl # 对应Kafka服务暴露的外部SSL端口
    tls:
      termination: edge
      insecureEdgeTerminationPolicy: Redirect
  

• 执行命令创建：oc apply -f kafka-external-route.yaml

3. 验证外部访问 #

用Kafka客户端工具测试，比如生产者：

kafka-console-producer.sh --broker-list kafka-external.apps.your-cluster.com:443 --topic test-topic --producer.config client.conf

client.conf需要配置SSL信任：

security.protocol=SSL
ssl.truststore.location=/path/to/truststore.jks
ssl.truststore.password=your-pass

注：OpenShift集群的CA证书可以从openshift-ingress命名空间的router-ca secret导出：oc extract secret/router-ca -n openshift-ingress --keys=tls.crt，再导入到信任库中。

常见坑点排查 #

• 检查Kafka日志，确认advertised.listeners配置正确，没有启动报错
• 用oc get route kafka-external看Route状态，确保Ingress列显示正常的集群域名
• 验证Kafka服务的端口映射：oc get svc kafka，确认external-ssl端口已暴露

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