Access Kafka安装在Windows 10上的小型集群上

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: {}

对于侦听器，我首先从平原：{}开始，但这只提供了类型为ClusterIP的服务，无法从外部访问(我确实需要从外部连接)。然后，我转向了一位善良的外部听众。

您可以在集群的配置下面执行以下操作：

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提供)。

暂时来说，我的配置是否都是正确的？我无法在集群上与生产者连接(当我试图发布数据时会得到一个超时错误)。

我试图连接到192.168.49.2:32372和192.168.49.2:30117，并且总是得到相同的超时错误。我也试着跑

my-cluster-kafka-external-bootstrap

• 迷你库贝服务-n kafka

和

my-cluster-kafka-0

• 迷你库贝服务-n kafka

我还是会犯同样的错误。

我想做的事有什么不对？

谢谢!

Answer 1

好吧，我找到答案了。我将服务类型更改为LoadBalancer，并启动了minikube隧道。

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