从本地机器访问在 minikube 中运行的 bitnami/kafka

Question

我正在尝试访问使用 helm 部署的 bitnami/kafka 集群。我需要能够从本地计算机向 kafka 发送消息，然后让我的 Pod 处理数据。

我使用以下命令来启动集群： helm install my-kafka bitnami/kafka

>>> kubectl get all 
NAME                       READY   STATUS    RESTARTS   AGE
pod/my-kafka-0             1/1     Running   0          32s
pod/my-kafka-zookeeper-0   1/1     Running   0          32s

NAME                                  TYPE        CLUSTER-IP       EXTERNAL-IP   PORT(S)                      AGE
service/kubernetes                    ClusterIP   10.96.0.1        <none>        443/TCP                      5d18h
service/my-kafka                      ClusterIP   10.110.208.220   <none>        9092/TCP                     32s
service/my-kafka-headless             ClusterIP   None             <none>        9092/TCP,9093/TCP            32s
service/my-kafka-zookeeper            ClusterIP   10.105.53.40     <none>        2181/TCP,2888/TCP,3888/TCP   32s
service/my-kafka-zookeeper-headless   ClusterIP   None             <none>        2181/TCP,2888/TCP,3888/TCP   32s

NAME                                  READY   AGE
statefulset.apps/my-kafka             1/1     32s
statefulset.apps/my-kafka-zookeeper   1/1     32s

然后我使用 minikube 使用 minikube service my-kafka 公开该服务

|-----------|----------|-------------|--------------|
| NAMESPACE |   NAME   | TARGET PORT |     URL      |
|-----------|----------|-------------|--------------|
| default   | my-kafka |             | No node port |
|-----------|----------|-------------|--------------|

              

Answer 1

我认为问题源于 Minikube 独立网络。 Helm Chart 自动将广告监听器的 Minikube 网络列入白名单。我通过重新配置 helm value.yaml 解决了类似的问题，如下所示：

externalAccess:
  enabled: true
  autoDiscovery:
    enabled: false
    image:
      registry: docker.io
      repository: bitnami/kubectl
      tag: 1.23.4-debian-10-r17
      pullPolicy: IfNotPresent
      pullSecrets: []
    resources:
      limits: {}
      requests: {}
  service:
    type: NodePort
    port: 9094
    loadBalancerIPs: []
    loadBalancerSourceRanges: []
    nodePorts:
      - 30000
      - 30001
      - 30002
    useHostIPs: false
    annotations: {}
    domain: 127.0.0.1