flink OracleCDC是不是还不支持DDL变更？

flink OracleCDC是不是还不支持DDL变更？怎么按照文档里面的Demo来操作开启了includeSchemaChanges 还是监听不到

展开

收起

真的很搞笑 2023-11-22 09:33:28 122 0

3 条回答

写回答

取消提交回答

小周sir

面对过去，不要迷离；面对未来，不必彷徨；活在今天，你只要把自己完全展示给别人看。
Flink CDC 支持同步 DDL 变更。您可以在 Flink CDC 任务中设置 include.schema.changes 参数为 true 来开启 DDL 同步。
以下是示例代码片段：
```
{
  "connector.class": "io.debezium.connector.oracle.OracleConnector",
  "offset.storage": "org.apache.kafka.connect.storage.FileOffsetBackingStore",
  "offset.storage.file.filename": "/path/to/offset/storage/file.dat",

  "database.server.name": "dbserver1",
  "database.hostname": "localhost",
  "database.port": "1521",
  "database.user": "hr",
  "database.password": "hr",
  "database.dbname": "pdborcl",

  "include.schema.changes": "true"
}
```
在上面的代码中，设置 include.schema.changes 参数为 true 后，Flink CDC 将开始监听 Oracle 数据库的 DDL 变更，并将这些变更发送到 Kafka 主题中。
需要注意的是，目前 Flink CDC 对于 Oracle DDL 同步的支持并不完美，可能存在一些已知的问题。在实际使用时，还需要结合具体情况进行调整和优化。
2023-11-29 13:35:39

赞同展开评论打赏
sunrr

Flink OracleCDC目前还不支持DDL变更。即使开启了includeSchemaChanges选项，也无法监听到DDL变更。这是因为Flink CDC是基于Debezium实现的，而Debezium在处理Oracle数据库时存在一些限制和问题。

如果您需要实时同步Oracle数据库的DDL变更，您可以考虑使用其他工具或方法，例如基于时间戳的轮询机制或者使用第三方库来捕获DDL变更事件。这些方法可能需要额外的开发工作和配置，但可以实现对DDL变更的监听和同步。

请注意，由于Flink CDC对于Oracle数据库的支持仍在不断发展和完善中，因此未来可能会有更多的改进和增强功能

2023-11-29 12:01:14

赞同展开评论打赏
小Lee
对于 Oracle CDC，虽然当前不支持直接监听 schema 变更事件，但在 FLINK CDC 的某些版本中可以通过以下方法实现这一功能：
1. 使用官方提供的监控脚本来监视 schema 变更事件。
2. 对于schema更改通知事件，您可以编写相应脚本，并通过 FTP 或邮件等方式提醒您。
3. 在 Flink CDC 的配置文件中添加适当的参数来处理 schema 变更事件。
4. 对于表的增删改查操作，请手动执行相应的操作，以确保数据一致性。
2023-11-22 17:00:41

赞同 1 展开评论打赏