docker - 如何在动态环境中设置 Kafka 安全性和监听器？

Question

这些资源为如何设置 kafka 安全性(加密 + ssl)和 kafka 监听器的好主意提供了很好的视角。

setting up ssl auth

听众和广告听众:a , b , c , d (来自融合的家伙 - Robin M)

但这似乎在静态环境中运行良好，那么动态环境呢？
当使用 K8S 和容器(通过 EC2 使用 k8s 的 docker 等)或其他一些编排框架时，主机名和副本数量(即使没有自动缩放场景)是事先不知道的。
那么我们如何动态创建证书、 keystore 和信任库。以及如何配置 listeners server.properties 文件中的动态值。

Answer 1

这将创建一个 kafka 代理，但作为负载均衡器

apiVersion: v1
kind: Service
metadata:
  annotations:
    cloud.google.com/load-balancer-type: Internal
  labels:
    app: kafka
  name: kafka-2-external
  namespace: default
spec:
  ports:
  - name: broker
    port: 9092
    protocol: TCP
    targetPort: kafka
  selector:
    app: kafka
    statefulset.kubernetes.io/pod-name: kafka-2
  sessionAffinity: None
  type: LoadBalancer