Kubernetes服务与kafka无法正常工作

1 回答

• 0

  如果使用状态集，则需要先部署服务 .

  在这里我的服务 .

  apiVersion: v1
  kind: Service
  metadata:
    name: zookeeper
    labels:
      app: zookeeper
  spec:
    clusterIP: None
    ports:
    - port: 2181
      name: client
    - port: 2888
      name: server
    - port: 3888
      name: leader-election
    selector:
      app: zookeeper
  

  这里是configmap（稍后使用）：

  apiVersion: v1
      kind: ConfigMap
      metadata:
        name: zookeeper-cm
      data:
        jvm.heap: "1G"
        tick: "2000"
        init: "10"
        sync: "5"
        client.cnxns: "60"
        snap.retain: "3"
        purge.interval: "0"
  

  在这里我的状态：

  apiVersion: apps/v1beta1
  kind: StatefulSet
  metadata:
    name: zookeeper
  spec:
    serviceName: zookeeper
    replicas: 1
    template:
      metadata:
        labels:
          app: zookeeper
      spec:
        affinity:
          podAntiAffinity:
            requiredDuringSchedulingIgnoredDuringExecution:
              - labelSelector:
                  matchExpressions:
                    - key: "app"
                      operator: In
                      values:
                      - zookeeper
                topologyKey: "kubernetes.io/hostname"
        containers:
        - name: zookeeper
          imagePullPolicy: IfNotPresent
          image: sorintdev/zookeeper:20171204m
          resources:
            requests:
              memory: 500Mi
              cpu: 200m
          ports:
          - containerPort: 2181
            name: client
          - containerPort: 2888
            name: server
          - containerPort: 3888
            name: leader-election
          env:
          - name : ZK_REPLICAS
            value: "1"
          - name : ZK_HEAP_SIZE
            valueFrom:
              configMapKeyRef:
                  name: zookeeper-cm
                  key: jvm.heap
          - name : ZK_TICK_TIME
            valueFrom:
              configMapKeyRef:
                  name: zookeeper-cm
                  key: tick
          - name : ZK_INIT_LIMIT
            valueFrom:
              configMapKeyRef:
                  name: zookeeper-cm
                  key: init
          - name : ZK_SYNC_LIMIT
            valueFrom:
              configMapKeyRef:
                  name: zookeeper-cm
                  key: tick
          - name : ZK_MAX_CLIENT_CNXNS
            valueFrom:
              configMapKeyRef:
                  name: zookeeper-cm
                  key: client.cnxns
          - name: ZK_SNAP_RETAIN_COUNT
            valueFrom:
              configMapKeyRef:
                  name: zookeeper-cm
                  key: snap.retain
          - name: ZK_PURGE_INTERVAL
            valueFrom:
              configMapKeyRef:
                  name: zookeeper-cm
                  key: purge.interval
          - name: ZK_CLIENT_PORT
            value: "2181"
          - name: ZK_SERVER_PORT
            value: "2888"
          - name: ZK_ELECTION_PORT
            value: "3888"
          command:
          - bash
          - -c
          - zkGenConfig.sh && zkServer.sh start-foreground
          readinessProbe:
            exec:
              command:
              - "zkOk.sh"
            initialDelaySeconds: 10
            timeoutSeconds: 5
          livenessProbe:
            exec:
              command:
              - "zkOk.sh"
            initialDelaySeconds: 10
            timeoutSeconds: 5
          volumeMounts:
          - name: data
            mountPath: /var/lib/zookeeper
        securityContext:
          runAsUser: 1000
          fsGroup: 1000
    volumeClaimTemplates:
    - metadata:
        name: data
      spec:
        resources:
          requests:
            storage: 1Gi
        accessModes:
        - ReadWriteOnce
        storageClassName: zookeeper-class
  

  部署了正在运行的zookeeper配置并且他们选择了主服务器后，您可以继续进行kafka部署 .

  部署zookeeper后，您的kafka配置必须通过该服务引用zookeeper statefulset . 在kafka中，您必须定义/覆盖此属性：

  --override zookeeper.connect=zookeeper-0.zookeeper:2181
  

  从一个吊舱内你应该成功地做到了.963649_ .

  希望这可以帮助 .

  回复于 2024-04-30T02:57:41+08:00