Strimzi kafka在GKE中私下访问

Question

我有两个集群，

一个集群安装了我的应用程序微服务，另一个集群安装了Strimzi kafka。两者都是私有的GKE集群。

我的挑战是如何从我的应用程序连接到这个 kafka。大约有 10 个微服务正在运行，每个微服务都必须连接到 kafka。

我现在有一种方法，将Strimzi kafka作为Nodeport服务，并在应用程序代码中提供Ip和nodeIp。

这种方法的问题在于，如果 GKE 节点自动更新，我将不得不重新配置代码。

还有一个更关键的条件是，Kafka只能由我们的应用程序访问。它不应该在公共互联网上使用。

Answer 1

我也有类似的情况以及我是如何解决的。

创建一个可从另一个AKS集群访问的内部负载均衡器。还允许访问特定子网。

Strimzi支持外部化引导服务。

示例:

...
spec:
  kafka:
    replicas: 3
    listeners:
      plain: {}
      tls: {}
      external:
        type: loadbalancer
        tls: false
    ...
    template:
      externalBootstrapService:
          metadata:
            annotations:
              service.beta.kubernetes.io/azure-load-balancer-internal: "true"
              service.beta.kubernetes.io/azure-load-balancer-internal-subnet: "apps-subnet"
      perPodService:
        metadata:
          annotations:
            service.beta.kubernetes.io/azure-load-balancer-internal: "true"
            service.beta.kubernetes.io/azure-load-balancer-internal-subnet: "apps-subnet"

要了解更多细节，您可以查看内部负载平衡器部分在这个链接:https://strimzi.io/blog/2019/05/13/accessing-kafka-part-4/