在使用Flink 1.13与mysql-cdc 2.4配合时，如何解决guava版本冲突并进行排除？

在使用Flink 1.13与mysql-cdc 2.4配合时，可能会遇到guava版本冲突的问题。以下是解决该问题的具体步骤和方法：

1. 确认依赖冲突

首先需要确认是否存在guava版本冲突。可以通过以下方式排查： - 使用mvn dependency:tree命令查看项目的依赖树，检查是否存在多个版本的guava依赖。 - 如果发现guava存在多个版本（例如Flink和mysql-cdc分别引入了不同版本的guava），则需要进行版本排除。

2. 排除冲突依赖

在Maven项目中，可以通过exclusions标签排除不必要的guava依赖。以下是具体操作步骤：

2.1 排查并定位冲突来源

通过mvn dependency:tree命令找到引入guava的具体依赖路径。例如：

+- org.apache.flink:flink-streaming-java_2.11:jar:1.13.0:compile
|  \- com.google.guava:guava:jar:28.0-jre:compile
+- io.debezium:debezium-connector-mysql:jar:2.4.0:compile
   \- com.google.guava:guava:jar:30.1.1-jre:compile

从上述输出可以看出，flink-streaming-java引入了guava:28.0-jre，而debezium-connector-mysql引入了guava:30.1.1-jre。

2.2 配置exclusions排除冲突

在pom.xml中，针对冲突的依赖添加exclusions配置。例如，如果希望保留guava:30.1.1-jre，可以排除flink-streaming-java中的guava依赖：

<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-streaming-java_2.11</artifactId>
    <version>${flink.version}</version>
    <scope>provided</scope>
    <exclusions>
        <exclusion>
            <groupId>com.google.guava</groupId>
            <artifactId>guava</artifactId>
        </exclusion>
    </exclusions>
</dependency>

3. 强制指定统一版本

为了避免其他潜在的版本冲突，可以在pom.xml中使用dependencyManagement强制指定guava的版本。例如：

<dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>com.google.guava</groupId>
            <artifactId>guava</artifactId>
            <version>30.1.1-jre</version>
        </dependency>
    </dependencies>
</dependencyManagement>

这样可以确保整个项目中只使用guava:30.1.1-jre版本。

4. 验证依赖冲突是否解决

完成上述配置后，重新运行mvn dependency:tree命令，确认guava依赖已统一为指定版本。如果没有冲突，则说明问题已解决。

5. 注意事项

• Flink依赖范围：Flink的核心依赖（如flink-streaming-java）建议设置为provided，以避免将不必要的依赖打包到作业JAR中。
• Connector依赖范围：对于mysql-cdc等Connector依赖，建议保持默认的compile范围，以确保其被打包到作业JAR中。
• 版本兼容性：确保选择的guava版本与Flink和mysql-cdc均兼容。如果不确定兼容性，可以参考官方文档或社区建议。

通过以上步骤，您可以有效解决Flink 1.13与mysql-cdc 2.4配合时的guava版本冲突问题，并确保项目的稳定运行。