# A headless service to create DNS records
apiVersion: v1
kind: Service
metadata:
  labels:
    app: kafka
  name: kafka
spec:
  clusterIP: None
  ports:
    - { name: "kafka", port: 9092 }
  selector:
    app: kafka
---
apiVersion: policy/v1beta1
kind: PodDisruptionBudget
metadata:
  name: kafka
spec:
  minAvailable: 2
  selector:
    matchLabels:
      app: kafka
---
apiVersion: apps/v1
kind: StatefulSet
metadata:
  name: kafka
  labels:
    app: kafka
spec:
  serviceName: kafka
  replicas: 3
  podManagementPolicy: Parallel
  updateStrategy:
    type: RollingUpdate
  selector:
    matchLabels:
      app: kafka
  template:
    metadata:
      labels:
        app: kafka
    spec:
      containers:
        - name: kafka
          image: wurstmeister/kafka:2.12-2.2.0
          env:
            - { name: KAFKA_LISTENERS,                      value: "PLAINTEXT://:9092" }
            - { name: HOSTNAME_COMMAND,                     value: "echo $HOSTNAME" }
            - { name: KAFKA_ADVERTISED_LISTENERS,           value: "PLAINTEXT://_{HOSTNAME_COMMAND}.kafka:9092" }
            - { name: BROKER_ID_COMMAND,                    value: "echo ${HOSTNAME##*-}" }
            - { name: KAFKA_HEAP_OPTS,                      value: "-Xms5g -Xmx5g" }
            - { name: KAFKA_ZOOKEEPER_CONNECT,              value: "zookeeper" }
            - { name: JMX_PORT,                             value: "9010" }
          resources:
            requests: { memory: "10Gi" }
            limits:   { memory: "10Gi" }
          ports:
            - { name: jmx-port, containerPort: 9010, protocol: TCP }
            - { name: broker-port, containerPort: 9092, protocol: TCP }
          readinessProbe:
            tcpSocket:
              port: 9092
            initialDelaySeconds: 30
          volumeMounts:
            - {name: pvc,    mountPath: /var/lib/kafka }
            - {name: tmp,    mountPath: /tmp }
            - {name: vartmp, mountPath: /var/tmp }
      volumes:
        - { name: tmp,    emptyDir: {} }
        - { name: vartmp, emptyDir: {} }
  volumeClaimTemplates:
    - metadata: { name: pvc }