Micronaut Kubernetes Operator监听全命名空间Pod事件遇空指针问题

问题描述 #

使用micronaut-kubernetes-operator创建Kubernetes Operator，目标是监听集群内所有命名空间的Pod事件。指定单个命名空间时代码可正常运行，但将namespace设置为Informer#ALL_NAMESPACES或空字符串时，接收请求会触发空指针异常。

正常运行的单命名空间代码 #

@Operator(
  informer = Informer(
    apiType = V1Pod::class,
    apiListType = V1PodList::class,
    resourcePlural = "pods",
    namespace = "my_namespace"
  )
)
class NetpolReconciler : ResourceReconciler<V1Pod> {

  override fun reconcile(
    request: Request,
    lister: OperatorResourceLister<V1Pod>,
  ): Result {
   // 业务逻辑实现
  }
}

触发的空指针异常日志 #

09:30:43.942 [OperatorV1Pod-controller-12] [traceId:,spanId:] ERROR i.k.c.e.controller.DefaultController - Reconciler aborted unexpectedly
java.lang.NullPointerException: Cannot invoke "io.kubernetes.client.informer.SharedIndexInformer.getIndexer()" because "sharedIndexInformer" is null
    at io.micronaut.kubernetes.client.operator.OperatorResourceLister.get(OperatorResourceLister.java:66)
    at operator.NetpolReconciler.reconcile(NetpolReconciler.kt:31)
    at io.micronaut.kubernetes.client.operator.controller.DefaultControllerBuilder.lambda$build$1(DefaultControllerBuilder.java:108)
    at io.kubernetes.client.extended.controller.DefaultController.worker(DefaultController.java:207)
    at io.kubernetes.client.extended.controller.DefaultController.lambda$run$1(DefaultController.java:154)

解答 #

micronaut-kubernetes-operator支持监听全命名空间的Pod事件，出现空指针异常是因为旧版本中存在全命名空间场景下OperatorResourceLister初始化不完整的问题，导致sharedIndexInformer未被正确注入。

解决方法 #

1. 升级依赖版本：该问题在micronaut-kubernetes-operator的新版本（如4.x系列）中已修复，建议直接升级到最新稳定版。
2. 替换lister使用方式：若暂时无法升级，可在reconcile方法中改用Kubernetes原生API查询资源，绕过有问题的OperatorResourceLister：

   @Inject
   lateinit var coreV1Api: CoreV1Api
   
   override fun reconcile(request: Request, lister: OperatorResourceLister<V1Pod>): Result {
       val pod = coreV1Api.readNamespacedPod(request.name, request.namespace, null)
       // 业务逻辑处理
       return Result.success()
   }
   

3. 验证集群权限：确保Operator对应的ServiceAccount拥有集群级别的Pod操作权限（需配置包含pods的list、watch、get权限的ClusterRole），避免因权限不足导致Informer无法同步资源。

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