连接到本地主机 Kafka pod

Question

我是 k8s 的新手，已经使用 helm install 命令将 Kafka 安装到本地集群并且安装成功并使用

显示

掌舵列表

并使用

kubectl get all -A

命令为运行。

我在我的 C# 项目中安装了 Confluent.Kafka nugget 包并尝试连接到 pod 但它没有使用 localhost:13090 连接并且没有给出错误消息

请注意pod的命名空间是“default”，而application pod的命名空间是“my-pod”

请指教，谢谢

Answer 1

我可以看到 90% 的答案都包含在你的问题中，你提到命名空间不同，这意味着你需要将“.default”添加到你的服务名称 .

您还提到了一个可能用于从外部集群连接但在集群内部的端口，您可以使用 9092 以及包含 headless 一词的服务。

示例

mykafka-service-headless.default:9092

或

mykafka-service-headless.default

没有端口，因为这是默认端口。

您不需要端口转发，但以防万一，您可以为主题 Kafka pods.[= 执行 9092 的 port-forward 命令。 13=]

connecting to localhost Kafka pod