Kafka Connect 2.6.2-LO运行TwitterSourceConnector类继承错误如何解决?
错误核心说明
你遇到的报错是Kafka Connect运行时的基础校验失败:部署的连接器实现类没有继承SourceConnector或SinkConnector父类,无法被框架识别加载。
可能的原因
- 内置连接器版本不兼容:landoop/fast-data-dev:2.6.2-LO内置的TwitterSourceConnector是针对旧版Kafka Connect开发的,适配版本低于2.6.x,类结构不符合新版接口规范
- 配置类名错误:你创建连接器时填写的
connector.class参数拼写错误,或者引用到了同路径下其他非连接器类 - 插件依赖冲突:镜像内置了数十款连接器,不同连接器的依赖包版本冲突,导致TwitterSourceConnector的父类加载失败,被JVM判定为未实现标准连接器接口
可行解决方案
- 首先校验插件类名:执行
curl http://localhost:8083/connector-plugins | grep Twitter查看当前节点可识别的Twitter连接器完整类名,替换你原有配置中的connector.class值后重新创建连接器 - 手动替换适配版本的连接器:下载适配Kafka Connect 2.6.x的Twitter连接器包,挂载到镜像的
/opt/landoop/connectors目录,重启Kafka Connect服务后重新部署 - 回退兼容镜像版本:更换镜像标签为
landoop/fast-data-dev:2.5.0-L0,该版本内置的Twitter连接器与Kafka Connect版本适配无兼容问题
内容的提问来源于stack exchange,提问作者Esteban Rincon
相关产品推荐
相关产品推荐

