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

Question

我正在尝试在Windows 10上运行的本地munikube集群上安装带有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，我总是得到相同的超时错误。我还试着运行

• minikube service -n kafka my-cluster-kafka-external-bootstrap

和

• minikube service -n kafka my-cluster-kafka-0

我仍然得到相同的错误

我想做的是什么错了?

谢谢!

Answer 1

好了，我知道答案了。我将服务类型更改为LoadBalancer，并启动minikube tunnel

还有一点，当我在windows上运行这个时，我注意到如果我使用powershell运行所有东西，它就会工作，如果我使用其他命令行工具(如Moba)它就不工作了，我不解释这个。