我通过 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 工作吗？