You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

Debezium v2.0.0无Kafka依赖Oracle连接器配置报错求助

解决Debezium Oracle连接器无Kafka依赖下的Schema History配置错误

方案1:禁用Schema History(使用内存存储)

如果你不需要捕获和持久化Schema变更,可以将Schema History切换为内存实现,完全绕过Kafka依赖:

  • 在连接器配置中添加以下参数:
    schema.history.internal=io.debezium.storage.memory.history.MemorySchemaHistory
    

这个实现会将Schema历史仅保存在内存中,重启连接器后历史会丢失,适合不需要追踪Schema变更的场景,也不需要任何Kafka相关配置。

方案2:自定义Schema History存储到Pub/Sub(进阶)

Debezium官方没有提供Pub/Sub的Schema History实现,但你可以通过自定义实现io.debezium.schema.SchemaHistory接口来适配:

  1. 实现SchemaHistory接口,编写Pub/Sub的读写逻辑,用于存储和加载Schema历史记录
  2. 将自定义类的全限定名配置到schema.history.internal参数中
    注意:这种方式需要自行维护自定义实现的兼容性,适合有定制开发能力的场景。

提示:Debezium v2.0.0中,schema.history.internal是替代旧版schema.history的新参数,确保配置的是这个新参数而非旧参数。

内容的提问来源于stack exchange,提问作者Dimon Buzz

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.08.08 07:20:39