kafka-sts.yaml

apiVersion: apps/v1
kind: StatefulSet
metadata: 
  labels: 
    app: kafka
  name: kafka
spec: 
  podManagementPolicy: OrderedReady
  replicas: 3
  revisionHistoryLimit: 1
  selector: 
    matchLabels: 
      app: kafka
  serviceName: kafka-headless
  template: 
    metadata: 
      labels: 
        app: kafka
    spec: 
      imagePullSecrets:
      - name: nexuspullsecret
      containers: 
        - command: 
            - sh
            - "-exc"
            - |
                unset KAFKA_PORT && \
                export KAFKA_BROKER_ID=${HOSTNAME##*-} && \
                export KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://${POD_IP}:9092 && \
                exec /etc/confluent/docker/run
          env: 
            - 
              name: POD_IP
              valueFrom: 
                fieldRef: 
                  apiVersion: v1
                  fieldPath: status.podIP
            - 
              name: KAFKA_HEAP_OPTS
              value: "-Xmx1G -Xms1G"
            - 
              name: KAFKA_ZOOKEEPER_CONNECT
              value: "zk-cs:2181"
            - 
              name: KAFKA_LOG_DIRS
              value: /opt/kafka/data/logs
            - 
              name: KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR
              value: "3"
            - 
              name: KAFKA_JMX_PORT
              value: "5555"
          image: "192.168.161.187:9050/confluentinc/cp-kafka:5.3.2"
          imagePullPolicy: IfNotPresent
          livenessProbe: 
            exec: 
              command: 
                - sh
                - "-ec"
                - "/usr/bin/jps | /bin/grep -q SupportedKafka"
            failureThreshold: 3
            initialDelaySeconds: 30
            periodSeconds: 10
            successThreshold: 1
            timeoutSeconds: 5
          name: kafka-broker
          ports: 
            - 
              containerPort: 9092
              name: kafka
              protocol: TCP
          readinessProbe: 
            failureThreshold: 3
            initialDelaySeconds: 30
            periodSeconds: 10
            successThreshold: 1
            tcpSocket: 
              port: kafka
            timeoutSeconds: 5
          resources: {}
          terminationMessagePath: /dev/termination-log
          terminationMessagePolicy: File
          volumeMounts: 
            - 
              mountPath: /opt/kafka/data
              name: kafka1
      dnsPolicy: ClusterFirst
      restartPolicy: Always
      schedulerName: default-scheduler
      securityContext: {}
      terminationGracePeriodSeconds: 60
  updateStrategy: 
    type: OnDelete
  volumeClaimTemplates: 
   - 
     metadata: 
       annotations: 
         volume.alpha.kubernetes.io/storage-class: default
       name: kafka1
     spec: 
       accessModes: 
         - ReadWriteOnce
       resources: 
         requests: 
           storage: 1Gi