大家有遇到过吗？

针对您遇到的Flink CDC Stream API报错问题：java.lang.IllegalAccessError: io/debezium/embedded/EmbeddedEngineChangeEvent，根据知识库中的相关信息，此错误可能与Debezium库的版本兼容性或类加载冲突有关。尽管直接参考资料未明确涵盖该特定错误，但我们可以基于相似问题的解决思路来尝试解决您的问题。

解决步骤

1. 检查依赖版本兼容性：

   • 确保您的Flink、Debezium以及所有相关库的版本之间是兼容的。不兼容的版本可能导致类路径冲突或缺失方法等问题。参考Debezium官方文档确认各组件间的版本匹配关系，并进行相应升级或降级操作。

2. 类加载隔离：

   • 如果您在使用Flink的自定义类加载器或是在一个复杂的类路径环境中，可能存在类加载冲突。考虑在Flink配置中对Debezium相关的依赖进行适当的类加载策略调整，确保Debezium的类由正确的类加载器加载。

3. 排除冲突依赖：

   • 检查项目中是否存在多个版本的Debezium依赖，这可能导致类路径上的混乱。使用Maven或Gradle的依赖排除功能，确保仅有一个统一版本的Debezium被引入到项目中。

4. 更新或回退Debezium版本：

   • 有时，最新版本的Debezium可能引入了不兼容的变更。如果上述步骤无效，尝试回退到一个稳定且已知与您的环境兼容的Debezium版本。

5. 清理和重建：

   • 清理项目的构建输出（如.m2/repository或.gradle/caches），然后重新构建项目，以消除可能的旧版本或损坏的依赖文件影响。

注意事项

• 在进行任何版本调整前，请务必备份当前的配置和依赖状态，以便于回滚。
• 实施更改后，彻底测试您的应用，确保修改没有引入新的问题。

如果以上建议仍不能解决您的问题，建议查看完整的错误日志，寻找更具体的错误上下文，并考虑将详细错误信息、环境配置及已尝试的解决方案一并提交给Flink或Debezium的社区论坛或官方支持渠道寻求帮助。您可以复制页面截图提供更多信息，我可以进一步帮您分析问题原因。