AKS集群自建Kafka Pod扩容失效及CA证书启动异常问题

1. CRD调整Pod副本数无效果 #

• 检查Kafka Operator运行状态：执行kubectl get pods -n <你的命名空间>，确认operator pod处于Running状态，无重启或异常日志。若异常，重启operator pod：kubectl delete pod <operator-pod-name> -n <命名空间>
• 验证CRD配置的副本字段：确认CRD spec中对应的副本参数正确（通常是spec.kafka.replicas），避免字段名错误或配置未应用
• 检查Operator权限：确认operator绑定的ClusterRole包含statefulsets的update/patch权限，若缺失，补充对应权限规则后重启operator

2. 手动修改StatefulSet后新Pod报“No CA found”错误 #

• 立即恢复StatefulSet到CRD管控状态：执行kubectl scale statefulset kafka-cluster-sc-kafka --replicas=<CRD原定义的副本数>，避免手动修改与operator管控冲突
• 检查CA证书Secret挂载配置：确认CRD管控的StatefulSet模板中，已正确挂载CA证书Secret（通常为<cluster-name>-ca-cert）到容器内指定路径（如/opt/kafka/certs/ca）。示例配置：

  spec:
    template:
      spec:
        volumes:
        - name: ca-cert
          secret:
            secretName: kafka-cluster-sc-ca-cert
        containers:
        - name: kafka
          volumeMounts:
          - name: ca-cert
            mountPath: /opt/kafka/certs/ca
            readOnly: true
  

• 重新触发Operator同步：修改CRD的副本数（可先改回原值再调整目标值），让operator重新生成符合配置的StatefulSet和Pod，确保新Pod能正确获取CA证书

3. CRD状态显示PodDisruptionBudget（PDB）404 #

• 检查Operator权限：确认operator的ClusterRole包含poddisruptionbudgets资源的create/get/update/delete权限，若缺失，更新ClusterRole后重启operator
• 强制重新创建PDB：删除CRD对应的PDB（若存在残留），然后重启operator，让其根据CRD配置重新生成PDB
• 验证CRD与Operator版本兼容性：确保使用的Kafka CRD与Operator版本匹配，若版本不兼容，升级或降级到对应匹配版本

内容的提问来源于stack exchange，提问作者endlessCode