运行Kafka JDBC Source Connector时出现类未找到错误求助

这个错误本质是JDBC Connector找不到org.apache.calcite.avatica.UnregisteredDriver类，结合你提到的「之前JDBC能正常工作，运行Twitter和FTP Connector后才出问题」的背景，大概率是插件类加载隔离冲突或者JDBC Connector的依赖被意外移除/覆盖导致的。下面是针对性的解决步骤：

1. 检查JDBC Connector的依赖完整性 #

先确认你的JDBC Connector插件目录下的lib文件夹里，是否存在calcite-avatica-*.jar文件。如果找不到这个jar，说明核心依赖缺失了：

• 去官方渠道下载完整的Kafka JDBC Connector包，把缺失的calcite-avatica相关jar包复制到JDBC Connector的lib目录中。
• 注意：不要随意修改或删除连接器lib目录下的文件，之前运行其他连接器时可能误操作了这个目录。

2. 用独立插件目录隔离连接器 #

Kafka Connect的类加载器如果加载多个共享目录的连接器，很容易出现依赖冲突。给每个连接器单独建一个插件目录：

• 停止所有Kafka Connect进程
• 把JDBC、Twitter、FTP连接器分别放到独立的文件夹，比如plugins/kafka-connect-jdbc/、plugins/kafka-connect-twitter/、plugins/kafka-connect-ftp/
• 修改Connect配置文件中的plugin.path，指向这些独立目录（用逗号分隔，比如plugin.path=/opt/kafka/plugins/kafka-connect-jdbc,/opt/kafka/plugins/kafka-connect-twitter,...）
• 先只启动JDBC Connector测试是否正常，再逐步添加其他连接器

3. 清理Connect的临时缓存 #

Connect会缓存插件的类信息，可能缓存了错误的依赖状态：

• 停止Connect进程后，删除Connect的偏移量文件（默认是/tmp/connect.offsets，如果配置了offset.storage.file.filename就删对应的文件）
• 清理插件类加载器的临时缓存目录（通常在/tmp下，前缀为connect-classloader-的文件夹）
• 重新启动Connect，让它重新加载所有插件的依赖

4. 重新安装JDBC Connector #

如果上面的步骤都没解决，可能之前的JDBC Connector包已经损坏：

• 完全删除现有的JDBC Connector目录
• 下载官方最新的稳定版JDBC Connector包，解压后放到插件目录中
• 再次启动Connect测试

额外排查提示 #

• 查看Connect的启动日志，有没有其他关于依赖冲突的警告信息，这能帮你定位具体是哪个依赖出了问题
• 确认你没有在运行其他连接器时修改过Connect的系统classpath，避免覆盖了JDBC Connector的依赖

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