FLINK CDC 版本2.1.1对接oracle 11g出现debezium engine 关闭？
具体错误为： Caused by: java.lang.IllegalStateException: Retrieve schema history failed, the schema records for engine e87aa165-4234-40f0-bb5b-54cfd8b4825c has been removed, this might because the debezium engine has been shutdown due to other errors. 有大佬怎么解决的吗，急求在线解答。
写回答
-
存在即是合理根据您提供的信息，问题可能是由于 Debezium 引擎关闭导致的。Debezium 是一个开源的分布式平台，用于将数据从各种源转换为 Apache Kafka。
在 FLINK CDC 版本2.1.1 中，它可以与 Oracle 11g 数据库进行连接。但是，由于 Debezium 引擎关闭，可能会导致无法检索模式历史记录，从而导致连接失败。
要解决此问题，您可以尝试以下步骤：
-
确保 Debezium 引擎正在运行。您可以通过检查 Debezium 控制台或日志来确认引擎是否正在运行。如果引擎未启动，请启动它并重试连接。
-
如果引擎已启动但仍然无法连接，请检查连接配置是否正确。确保您已经正确配置了连接参数，例如连接地址、端口、用户名和密码等。
-
如果连接配置正确但仍然无法连接，请检查 Oracle 数据库是否可用。您可以尝试使用其他工具(例如 SQL*Plus)连接到 Oracle 数据库并查看是否可以正常访问。
-
如果 Oracle 数据库可用但仍然无法连接，请检查 Debezium 配置文件是否正确。您可以检查 Debezium 配置文件中的连接参数是否正确，并尝试重新启动 Debezium 引擎以清除任何可能的问题。
希望这些步骤可以帮助您解决问题。
2023-05-19 18:25:06赞同 展开评论 打赏 -
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。
热门讨论
热门文章
相关课程
更多
相关电子书
更多
