我通过Kubernetes部署了Kafka部署和服务。它的每个pod都有它的内部IP和这样的命令
kubectl描述服务代理–namespace = kafka | grep端点| …
您应该在python中开发一个客户端程序,或者使用安装在每个容器中的服务帐户,点击api服务器端点并检索Kafka端点。解析Json文件输出abd抓取实际的代理ip地址
Kubernetes允许您使用环境变量。 这是文档 。
您还可以使用HELM来使用也允许使用环境变量的模板。
在您的情况下,您可以将结果输入env变量,如下所示:
SOME_ENV_VARIABLE = $(命令......)