访问 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,但总是出现相同的超时错误。我也试过 运行
- minikube service -n kafka my-cluster-kafka-external-bootstrap
和
- minikube 服务-n kafka my-cluster-kafka-0
我仍然得到同样的错误。
我正在尝试做的事情有什么问题?
谢谢!
好的,我得到答案了。
我将服务类型更改为 LoadBalancer 并启动了 minikube 隧道
还有一点,当我在 windows 上 运行 进行此操作时,我注意到如果我 运行 使用 powershell 的所有内容都有效,如果我使用其他命令行工具(如 Moba)它不起作用,我不解释这个。
我正在尝试在 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,但总是出现相同的超时错误。我也试过 运行
- minikube service -n kafka my-cluster-kafka-external-bootstrap
和
- minikube 服务-n kafka my-cluster-kafka-0
我仍然得到同样的错误。
我正在尝试做的事情有什么问题?
谢谢!
好的,我得到答案了。 我将服务类型更改为 LoadBalancer 并启动了 minikube 隧道
还有一点,当我在 windows 上 运行 进行此操作时,我注意到如果我 运行 使用 powershell 的所有内容都有效,如果我使用其他命令行工具(如 Moba)它不起作用,我不解释这个。