0

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

我的 YAML 取自GitHub 上的 Strimizi 示例，如下所示：

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-0andmy-cluster-kafka-external-bootstrap有一个<pending> EXTERNAL-IP. 我的 YAML 文件中缺少什么来提供双向外部访问my-cluster-kafka-0？

4

1 回答 1

0

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

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

            advertisedHost: 10.0.0.200
            advertisedPort: 30123

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

于 2021-10-28T15:45:53.200 回答