求含SinkConnector.class的MySQL Sink Connector Jar包用于Kafka数据拉取
MySQL Sink Connector Jar包获取与类验证
官方可靠选项:Confluent维护的Kafka Connect MySQL Sink Connector是工业界常用版本,你可以从其Maven仓库下载对应版本的Jar包。下载后,用以下命令检查是否包含
SinkConnector.class(官方实现中,MySQL Sink基于JDBC Connector,对应类为JdbcSinkConnector,它实现了SinkConnector接口):jar tf mysql-connector-sink-<your-version>.jar | grep "SinkConnector.class"若输出包含
io/confluent/connect/jdbc/sink/JdbcSinkConnector.class,则符合你的需求。自定义构建方案:如果需要定制化修改,可自行构建Jar包:
- 拉取Kafka Connect JDBC项目源码
- 根据MySQL场景调整代码或配置(按需)
- 执行Maven构建:
mvn clean package -DskipTests - 在
target目录找到生成的Jar包,用上述命令验证目标类是否存在
注意:务必选择与你的Kafka集群版本匹配的Connector版本,避免兼容性问题。
内容的提问来源于stack exchange,提问作者abdelrahman
相关产品推荐
相关产品推荐

