Kubernetes集群NiFi中配置DBCPConnectionPool连MySQL遇驱动缺失错误

错误信息 #

StandardControllerServiceNode[service=DBCPConnectionPool[id=c91863c8-018c-1000-4807-b1f99934eaaf], name=DBCPConnectionPool, active=true] Failed to invoke @OnEnabled method: org.apache.nifi.processor.exception.ProcessException: Driver class cdata.jdbc.mysql.MySQLDriver is not found

解决方法 #

方式一：通过Kubernetes挂载驱动包到NiFi实例

1. 下载对应版本的CData MySQL JDBC驱动包（cdata.jdbc.mysql.jar）
2. 创建ConfigMap存储驱动包：

   kubectl create configmap mysql-jdbc-driver --from-file=cdata.jdbc.mysql.jar -n nifi
   

3. 修改NiFi的Deployment配置，添加卷挂载：

   volumes:
     - name: mysql-driver
       configMap:
         name: mysql-jdbc-driver
   containers:
     - name: nifi
       volumeMounts:
         - name: mysql-driver
           mountPath: /opt/nifi/nifi-current/lib/
   

4. 重新部署NiFi：

   kubectl apply -f nifi-deployment.yaml -n nifi
   

方式二：自定义NiFi镜像内置驱动包

1. 创建Dockerfile：

   FROM apache/nifi:latest
   COPY cdata.jdbc.mysql.jar /opt/nifi/nifi-current/lib/
   

2. 构建并推送自定义镜像：

   docker build -t custom-nifi:with-mysql-driver .
   # 推送至你的镜像仓库，比如：docker push your-registry/custom-nifi:with-mysql-driver
   

3. 修改NiFi Deployment的镜像地址为自定义镜像，重新部署。

方式三：通过NiFi UI上传驱动包（需有UI访问权限）

1. 登录NiFi UI，点击右上角齿轮图标进入Controller Settings
2. 切换到Classpath标签页，点击Add上传本地的cdata.jdbc.mysql.jar
3. 重启NiFi实例，确保驱动包加载生效

验证操作 #

重新启用DBCPConnectionPool服务，检查错误是否消失，也可以在服务配置页点击Test Connection确认连接正常。

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