You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

求含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包:

    1. 拉取Kafka Connect JDBC项目源码
    2. 根据MySQL场景调整代码或配置(按需)
    3. 执行Maven构建:
      mvn clean package -DskipTests
      
    4. 在target目录找到生成的Jar包,用上述命令验证目标类是否存在

注意:务必选择与你的Kafka集群版本匹配的Connector版本,避免兼容性问题。

内容的提问来源于stack exchange,提问作者abdelrahman

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.08.20 18:48:41