kubernetes - 创建kafka容器时如何修复 “crashLoopBackoff”

Question

我正在设置具有高可用性的kafka和zookeeper集群。我有2个kafka代理(pod1，pod2)和3个zookeeper(pod1，pod2，pod3)。设置工作正常。当我进入一个kafka经纪人(pod1)时，我就能产生和使用该消息。但是当我进入另一个kafka broker(pod2)时，虽然我将复制因子设置为2，但是却无法收到任何消息，因此我在容器规范中添加了卷，现在我无法创建任何pod获取crashloopbackoff。

当我检查日志时，信息如下:
对服务器的请求错误。容器无法创建。

kafka_pod.yaml包含kafka部署。

apiVersion: apps/v1
kind: Deployment
metadata:
  name: kafka
  labels:
    app: kafka
spec:
  replicas: 2
  selector:
    matchLabels:
      app: kafka
  template:
    metadata:
      labels:
        app: kafka
    spec:
      hostname: kafka
      containers:
      - name: kafka
        image: wurstmeister/kafka:2.11-1.0.2
        ports:
        - containerPort: 9092
          protocol: TCP
        env:
         - name: KAFKA_ADVERTISED_HOST_NAME
           value: kafka
         - name: KAFKA_ADVERTISED_PORT 
           value: "9092"
         - name: KAFKA_ZOOKEEPER_CONNECT
           value: zookeeper:2181
         - name: KAFKA_OFFSET_TOPIC_REPLICATION_FACTOR
           value: "2"
         - name: KAFKA_AUTO_CREATE_TOPICS_ENABLE
           value: "true"
         - name: KAFKA_LOG_DIRS
           value: /opt/kafka
        volumeMounts:
        - name: socket
          mountPath: /var/run/docker.sock
        - name: logdir
          mountPath: /opt/kafka
      volumes:
      - name: socket
        hostPath:
         path: /var/run/docker.sock
      - name: logdir
        hostPath:
         path: ~/datadir

zookeeper_pod.yaml contains the following.
apiVersion: v1
kind: Service
metadata:
  name: zookeeper
spec:
  ports:
  - port: 2181
  selector:
    app: zookeeper
  clusterIP: None
---
apiVersion: apps/v1
kind: Deployment
metadata:
  name: zookeeper
  labels:
    app: zookeeper
spec:
  replicas: 3
  selector:
    matchLabels:
      app: zookeeper
  template:
    metadata:
      labels:
        app: zookeeper
    spec:
      nodeName: akshatha-ha
      containers:
      - name: zookeeper
        image: wurstmeister/zookeeper
        ports:
        - containerPort: 2181
          protocol: TCP

我需要部署带有两个代理的kafka和带有3个服务器的zookeeper。当其中一个服务器出现故障时，另一个服务器应该能够提供数据。

Answer 1

使用StatefulSets部署Kafka和zookeeper。 Kubernetes.io网站上的Zookeeper StatefulSets上有一个很好的教程。跟随那个。

如果您未运行单节点群集，请避免使用hostpath。使用永久卷或临时存储。如果您使用的是版本1.14，请考虑使用本地持久卷作为有状态集