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接口来适配:
- 实现
SchemaHistory接口,编写Pub/Sub的读写逻辑,用于存储和加载Schema历史记录 - 将自定义类的全限定名配置到
schema.history.internal参数中
注意:这种方式需要自行维护自定义实现的兼容性,适合有定制开发能力的场景。
提示:Debezium v2.0.0中,
schema.history.internal是替代旧版schema.history的新参数,确保配置的是这个新参数而非旧参数。
内容的提问来源于stack exchange,提问作者Dimon Buzz
相关产品推荐
相关产品推荐

