1

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

掌舵列表

并使用

Kubectl 获取所有 -A

命令作为运行。

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

请注意,pod 的命名空间是“default”,而应用程序 pod 的命名空间是“my-pod”</p>

请指教,谢谢

4

1 回答 1

3

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

您还提到了一个可能用于从外部集群连接但在集群内部的端口,您可以将9092与包含无头一词的服务一起使用。

例子

mykafka-service-headless.default:9092

或者

mykafka-service-headless.default

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

您不需要端口转发,但以防万一,您可以port-forward为主题 Kafka pod 执行 9092 的命令。

于 2021-02-20T15:00:17.887 回答