访问 Windows 10 上安装在 minikube 集群上的 Kafka

Access Kafka installed on a minikube cluster on Windows 10

我正在尝试在 Windows10 上的本地 munikube 集群 运行ning 上使用 Strimzy 安装 Kafka,以测试不同参数(尤其是 TLS 配置)的影响。在转向 TLS 之前,我只想连接到我的集群 :)

这是我的 yaml 配置:

apiVersion: kafka.strimzi.io/v1beta1
kind: Kafka
metadata:
  name: my-cluster
spec:
  kafka:
    version: 2.3.0
    replicas: 1
    listeners:
      external:
        type: nodeport
        tls: false
    config:
      offsets.topic.replication.factor: 1
      transaction.state.log.replication.factor: 1
      transaction.state.log.min.isr: 1
      log.message.format.version: "2.3"
    storage:
      type: persistent-claim
      size: 1Gi
  zookeeper:
    replicas: 1
    storage:
      type: persistent-claim
      size: 2Gi
      deleteClaim: false
  entityOperator:
    topicOperator: {}
    userOperator: {}

对于监听器,我首先从 plain: {} 开始,但这只给我 ClusterIP 类型的服务,无法从 minikube 外部访问(我真的需要从外部连接)。 然后我转向了一个外部的听众。

您可以在集群的配置下面找到:

kubectl get all -n kafka
NAME                                             READY   STATUS    RESTARTS   AGE
pod/my-cluster-entity-operator-9657c9d79-8hknc   3/3     Running   0          17m
pod/my-cluster-kafka-0                           2/2     Running   0          18m
pod/my-cluster-zookeeper-0                       2/2     Running   0          18m
pod/strimzi-cluster-operator-f77b7d544-hq5pq     1/1     Running   0          5h22m

NAME                                          TYPE        CLUSTER-IP       EXTERNAL-IP   PORT(S)                      AGE
service/my-cluster-kafka-0                    NodePort    10.99.3.204      <none>        9094:30117/TCP               18m
service/my-cluster-kafka-bootstrap            ClusterIP   10.106.176.111   <none>        9091/TCP                     18m
service/my-cluster-kafka-brokers              ClusterIP   None             <none>        9091/TCP                     18m
service/my-cluster-kafka-external-bootstrap   NodePort    10.109.235.156   <none>        9094:32372/TCP               18m
service/my-cluster-zookeeper-client           ClusterIP   10.97.2.69       <none>        2181/TCP                     18m
service/my-cluster-zookeeper-nodes            ClusterIP   None             <none>        2181/TCP,2888/TCP,3888/TCP   18m

NAME                                         READY   UP-TO-DATE   AVAILABLE   AGE
deployment.apps/my-cluster-entity-operator   1/1     1            1           17m
deployment.apps/strimzi-cluster-operator     1/1     1            1           5h22m

minikube集群IP地址为192.168.49.2(minikube ip给定)

暂时,我的配置是否正确?我无法在集群上连接生产者(尝试发布数据时出现超时错误)。

我尝试连接到 192.168.49.2:32372 和 192.168.49.2:30117,但总是出现相同的超时错误。我也试过 运行

我仍然得到同样的错误。

我正在尝试做的事情有什么问题?

谢谢!

好的,我得到答案了。 我将服务类型更改为 LoadBalancer 并启动了 minikube 隧道

还有一点,当我在 windows 上 运行 进行此操作时,我注意到如果我 运行 使用 powershell 的所有内容都有效,如果我使用其他命令行工具(如 Moba)它不起作用,我不解释这个。