如何与 Kafka KUDO Internal Setup 对话？
How to talk to Kafka KUDO Internal Setup?
我通过 KUDO 安装了 Kafka：
https://kudo.dev/docs/runbooks/kafka/external-access.html#internal-access
KUDO Kafka 有无头服务。
如何为 kafka 创建主题？
我已经安装了kafkacat CLI工具：
https://github.com/edenhill/kafkacat
我试图将一个 borker IP 从服务器端口转发到我的本地机器：
kubectl -n kafka port-forward kf-kafka-0 9092
端口转发有效，但发出 kafkacat 命令失败：
kafkacat -b localhost:9092 -C -t test
% ERROR: Topic test error: Broker: Leader not available
我可以安装一些其他工具来创建主题并测试该主题中是否有消息。
我想到的唯一其他方法实际上是在 k8s 上部署一个产生消息的服务，并检查 pod 的事件是否有错误
有什么方法可以让 kafkacat 正常工作？
找到答案：
使用 kubefwd CLI
我通过 KUDO 安装了 Kafka：
https://kudo.dev/docs/runbooks/kafka/external-access.html#internal-access
KUDO Kafka 有无头服务。
如何为 kafka 创建主题？
我已经安装了kafkacat CLI工具：
https://github.com/edenhill/kafkacat
我试图将一个 borker IP 从服务器端口转发到我的本地机器：
kubectl -n kafka port-forward kf-kafka-0 9092
端口转发有效，但发出 kafkacat 命令失败：
kafkacat -b localhost:9092 -C -t test
% ERROR: Topic test error: Broker: Leader not available
我可以安装一些其他工具来创建主题并测试该主题中是否有消息。
我想到的唯一其他方法实际上是在 k8s 上部署一个产生消息的服务，并检查 pod 的事件是否有错误
有什么方法可以让 kafkacat 正常工作？
找到答案：
使用 kubefwd CLI