docker run -d --name kafka \
  -p 9092:9092 \
  -e KAFKA_CFG_NODE_ID=1 \
  docker.io/apecloud/kafka:latest

docker run -d --name kafka \
  --restart unless-stopped \
  -p 9092:9092 \
  -v /data/kafka:/bitnami/kafka \
  -e KAFKA_CFG_PROCESS_ROLES=broker,controller \
  docker.io/apecloud/kafka:3.6.0

apiVersion: apps/v1
kind: StatefulSet
metadata:
  name: kafka
spec:
  serviceName: kafka
  replicas: 3
  selector:
    matchLabels:
      app: kafka
  template:
    metadata:
      labels:
        app: kafka
    spec:
      containers:
        - name: kafka
          image: docker.io/apecloud/kafka:3.6.0
          ports:
            - containerPort: 9092
          volumeMounts:
            - name: data
              mountPath: /bitnami/kafka
  volumeClaimTemplates:
    - metadata:
        name: data
      spec:
        accessModes: [ReadWriteOnce]
        resources:
          requests:
            storage: 50Gi
---
apiVersion: v1
kind: Service
metadata:
  name: kafka
spec:
  selector:
    app: kafka
  ports:
    - port: 9092
      targetPort: 9092