方法一:通过 Linux ,grep -r ClassPath 命令
grep -f org.apache.kafka.connect.source.SourceRecord
在 jar 包所在 lib 或者 lib/plugins 目录下执行,grep -r,
flink-sql-connector-sqlserver-cdc-3.3.0.jar 中此 kafka SourceRecord类 ,存在:
flink-sql-connector-sqlserver-cdc-3.0.1.jar 中此 kafka SourceRecord类 ,不存在:
方法二:搜索 jar 包 在 mavenrepository.com 查看对应 pom 文件 include artifacts
可以看到此 flink-sql-connector-sqlserver-cdc-3.0.1.jar 已经是由过去的 com.ververica 公司下提供,而 Flink 在过去版本转交 org.apache 组织负责,所以新的 flink-sql-connector-sqlserver-cdc-3.3.0.jar 自然更新丰富了内容,虽然两个都提供了 Kafka artifact 工件,但是新的 jar 还提供了 org.apache.kafka.connect.source.SourceRecord 新开发的类