Spring Boot Kubernetes选主失效：多Pod定时任务单Pod执行问题排查

针对你在GCP Kubernetes上使用Spring Boot 3.2.5结合spring-cloud-kubernetes-fabric8-leader实现选主失败的情况，按以下步骤逐一排查：

1. 版本兼容性检查 #

Spring Boot 3.2.x对应的Spring Cloud版本是2023.0.x（Leyton），你当前使用的spring-cloud-kubernetes-fabric8-autoconfig:2.1.6和spring-cloud-kubernetes-fabric8-leader:2.1.6是适配Spring Boot 2.7.x的旧版本，版本不匹配会直接导致自动配置失效。

调整build.gradle中的依赖版本至适配Spring Boot 3.2.x的版本：

// 使用Spring Cloud Kubernetes 3.1.x版本（对应Spring Boot 3.2.x）
implementation 'org.springframework.cloud:spring-cloud-kubernetes-fabric8-autoconfig:3.1.2'
implementation 'org.springframework.cloud:spring-cloud-kubernetes-fabric8-leader:3.1.2'

2. Kubernetes权限配置验证 #

Spring Cloud Kubernetes Leader Election默认通过ConfigMap实现分布式锁，Pod的ServiceAccount必须具备操作ConfigMap的权限。在GCP Kubernetes中，检查并配置RBAC规则：

创建Role：

apiVersion: rbac.authorization.k8s.io/v1
kind: Role
metadata:
  name: leader-election-role
  namespace: your-namespace # 替换为你的Pod所在命名空间
rules:
- apiGroups: [""]
  resources: ["configmaps"]
  verbs: ["get", "create", "update", "patch", "delete"]

创建RoleBinding绑定到Pod的ServiceAccount：

apiVersion: rbac.authorization.k8s.io/v1
kind: RoleBinding
metadata:
  name: leader-election-binding
  namespace: your-namespace
subjects:
- kind: ServiceAccount
  name: default # 替换为你的Pod使用的ServiceAccount名称
roleRef:
  kind: Role
  name: leader-election-role
  apiGroup: rbac.authorization.k8s.io

3. 核心配置细节检查 #

• 显式指定选主用的ConfigMap名称，避免默认值匹配问题：

  spring.cloud.kubernetes.leader.config-map-name=feeds-qa-leader-lock
  

• 确认spring.cloud.kubernetes.enabled=true（默认开启，但显式配置更稳妥）
• 在Pod内执行curl http://kubernetes/api/v1/namespaces/your-namespace/configmaps，验证Pod是否能正常访问Kubernetes API。

4. 代码与组件扫描验证 #

• 主启动类必须添加@EnableScheduling注解，否则@Scheduled定时任务不会生效：

  @SpringBootApplication
  @EnableScheduling
  public class FeedsQaApplication {
      public static void main(String[] args) {
          SpringApplication.run(FeedsQaApplication.class, args);
      }
  }
  

• 确认MyCronJob类的包路径被Spring组件扫描覆盖，@Component注解生效
• 检查事件监听器的导入包是否正确：

  import org.springframework.cloud.kubernetes.fabric8.leader.event.OnGrantedEvent;
  import org.springframework.cloud.kubernetes.fabric8.leader.event.OnRevokedEvent;
  

5. 日志排查 #

调整日志级别为DEBUG，查看选主过程中的详细错误信息：

logging.level.org.springframework.cloud.kubernetes=DEBUG
logging.level.org.springframework.integration=DEBUG

重点关注以下日志：

• ConfigMap创建/更新失败的权限错误
• 选主锁竞争的异常信息
• Leader选举初始化的日志输出

6. 分步测试验证 #

• 先启动单个Pod，观察日志是否输出Leadership granted to this pod.，确认单实例选主正常
• 再启动第二个Pod，观察第一个Pod是否保持leader身份，第二个Pod日志是否显示I am not the leader - I did nothing.
• 删除leader Pod，观察剩余Pod是否触发OnGrantedEvent并成为新leader

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