连接到本地 Kafka pod答案

【问题标题】：connecting to localhost Kafka pod连接到本地 Kafka pod
【发布时间】：2021-05-23 06:27:16
【问题描述】：

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

舵列表

并使用

Kubectl 获取所有 -A

命令正在运行。

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

请注意，pod 的命名空间是“default”，而应用程序 pod 的命名空间是“my-pod”

请指教，谢谢

【问题讨论】：

localhost 是 pod 本身，而不是另一个 pod 或运行 pod 的节点。 Kafka 图表将包含一个访问代理 pod 的服务，您需要使用该服务的名称作为主机名。

【解决方案1】：

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

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

例子

mykafka-service-headless.default:9092

或

mykafka-service-headless.default

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

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

【讨论】：