apiVersion: v1
kind: Service
metadata:
  name: kafka-headless
  namespace: tools  # 使用 tools 命名空间
  labels:
    app: kafka
spec:
  clusterIP: None  # Headless Service
  selector:
    app: kafka
  ports:
  - port: 9092
    targetPort: 9092
    name: plaintext
  - port: 8081
    targetPort: 8081
    name: schema-registry
  - port: 8083
    targetPort: 8083
    name: connect
  - port: 3030
    targetPort: 3030
    name: control-center
---
apiVersion: v1
kind: Service
metadata:
  name: kafka-nodeport
  namespace: tools  # 使用 tools 命名空间
  labels:
    app: kafka
spec:
  type: NodePort
  selector:
    app: kafka
  ports:
  - port: 9092
    targetPort: 9092
    name: plaintext
  - port: 8081
    targetPort: 8081
    name: schema-registry
  - port: 8083
    targetPort: 8083
    name: connect
  - port: 3030
    targetPort: 3030
    name: control-center
---
apiVersion: apps/v1
kind: StatefulSet
metadata:
  name: kafka
  namespace: tools  # 使用 tools 命名空间
spec:
  serviceName: "kafka-headless"
  replicas: 1
  selector:
    matchLabels:
      app: kafka
  template:
    metadata:
      labels:
        app: kafka
    spec:
      containers:
      - name: kafka
        image: harbor.haidaifu.net/base/fast-data-dev:3.9.0_v1
        imagePullPolicy: IfNotPresent
        securityContext:
          runAsUser: 0  # root 用户
        env:
        - name: ADV_HOST
          value: "kafka-headless.tools.svc.cluster.local"  # 更新为内部服务域名
        - name: RUNNING_SAMPLEDATA
          value: "1"
        - name: RUNTESTS
          value: "0"
        - name: KAFKA_LISTENERS
          value: "PLAINTEXT://:9092,DOCKERCOMPOSE://:19092,CONTROLLER://:16062"
        - name: KAFKA_ADVERTISED_LISTENERS
          value: "PLAINTEXT://kafka-headless.tools.svc.cluster.local:9092,DOCKERCOMPOSE://kafka-0.kafka-headless.tools.svc.cluster.local:19092"
        - name: KAFKA_LISTENER_SECURITY_PROTOCOL_MAP
          value: "DOCKERCOMPOSE:PLAINTEXT,CONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT,SSL:SSL,SASL_PLAINTEXT:SASL_PLAINTEXT,SASL_SSL:SASL_SSL"
        ports:
        - containerPort: 9092
          name: plaintext
        - containerPort: 19092
          name: dockercompose
        - containerPort: 16062
          name: controller
        - containerPort: 8081
          name: schema-registry
        - containerPort: 8083
          name: connect
        - containerPort: 3030
          name: control-center
        volumeMounts:
        - name: data
          mountPath: /data
  volumeClaimTemplates:
  - metadata:
      name: data
    spec:
      accessModes: ["ReadWriteOnce"]
      storageClassName: alicloud-disk-efficiency
      resources:
        requests:
          storage: 20Gi