使用 Strimzi 外部访问 Kafka

Question

我正在尝试按照以下指南使用 Strimzi 提供对 Kafka 的双向外部访问：Red Hat Developer - Kafka in Kubernetes

apiVersion: kafka.strimzi.io/v1beta2
kind: Kafka
metadata:
  name: my-cluster
spec:
  kafka:
    version: 3.0.0
    replicas: 1 #3
    listeners:
      - name: plain
        port: 9092
        type: internal
        tls: false
      - name: tls
        port: 9093
        type: internal
        tls: true
      - name: external
        port: 9094
        type: loadbalancer
        tls: false
        configuration:
          #externalTrafficPolicy: Local
          #loadBalancerSourceRanges:
          #  - 10.0.0.200/32
          brokers:
          - broker: 0
            advertisedHost: 10.0.0.200
            advertisedPort: 30123
    config:
      offsets.topic.replication.factor: 1 #3
      transaction.state.log.replication.factor: 1 #3
      transaction.state.log.min.isr: 1 #2
      log.message.format.version: "3.0"
      inter.broker.protocol.version: "3.0"
    storage:
      type: ephemeral
  zookeeper:
    replicas: 1 #3
    storage:
      type: ephemeral
  entityOperator:
    topicOperator: {}
    userOperator: {}

当运行 kubectl get services 我看到以下内容时：

NAME                                  TYPE           CLUSTER-IP      EXTERNAL-IP   PORT(S)                               AGE
kubernetes                            ClusterIP      10.96.0.1       <none>        443/TCP                               48m
my-cluster-kafka-0                    LoadBalancer   10.107.190.96   <pending>     9094:31964/TCP                        29m
my-cluster-kafka-bootstrap            ClusterIP      10.99.34.246    <none>        9091/TCP,9092/TCP,9093/TCP            43m
my-cluster-kafka-brokers              ClusterIP      None            <none>        9090/TCP,9091/TCP,9092/TCP,9093/TCP   43m
my-cluster-kafka-external-bootstrap   LoadBalancer   10.99.91.68     <pending>     9094:31442/TCP                        29m
my-cluster-zookeeper-client           ClusterIP      10.101.216.35   <none>        2181/TCP                              45m
my-cluster-zookeeper-nodes            ClusterIP      None            <none>        2181/TCP,2888/TCP,3888/TCP            45m

注意 my-cluster-kafka-0 和 my-cluster-kafka-external-bootstrap 有一个 <pending> EXTERNAL-IP。我的 YAML 文件中缺少什么来提供对 my-cluster-kafka-0 的双向外部访问？

Answer 1

Strimzi 刚刚创建了 Loadbalancer 类型的 Kubernetes 服务。由您的 Kubernetes 集群提供负载均衡器并设置 Strimzi 可以使用的外部地址。当外部地址被列为 pending 时，这意味着负载平衡器尚未（尚未）创建。在某些 public 云中可能需要几分钟，所以可能只是等待它。但请记住，并非所有环境都支持负载均衡器 => 并且当它们不受支持时，您无法真正使用它们。所以你真的需要仔细检查你的环境是否支持它们。通常，不同的云会支持负载均衡器，而某些本地或裸机环境可能不支持（但这确实取决于）。

我也不太确定你为什么要配置广告主机和端口：

            advertisedHost: 10.0.0.200
            advertisedPort: 30123

使用负载均衡器时（假设您的环境支持它们），您通常希望使用将自动设置为广告主机/端口的负载均衡器地址。除此之外，您的 YAML 看起来不错，但可能缺少负载平衡器支持。

使用 Strimzi 外部访问 Kafka

External access to Kafka using Strimzi

kubernetes

networking

apache-kafka

infrastructure

strimzi