Hi,casel.chen。
这个部分应该是在 CDC 项目里没有涉及到,CDC 依赖 debezium 的 engine 部分直接读取出变更数据,并没有像 debezium
本身一样去写入到 Kafka 中。
可以考虑去 Debezium 社区咨询一下这部分的内容,Debezium开发者们应该更熟悉这部分的内容。
祝好,
Hang
casel.chen 于2024年2月29日周四 18:11写道:
> 搜索了debezium源码但没有发现哪里有调用
> SchemaRegistryClient.register方法的地方,请问它是如何注册schema到confluent
你好,ha.fengqi。
MySQL CDC
连接器只有在多并发时,会依赖checkpoint的完成来切换到增量阶段。从你提供的代码上来看,是单并发的运行作业,所以应该Source
在这两者之间的行为不会有区别。
这个不同是不是有可能是下游在两种使用方式上,有什么区别?
可以通过观察具体的IO指标看到Source是否真的及时发出消息,如果比较熟悉代码,也可以自己添加一下打印日志来验证。
祝好,
Hang
搜索了debezium源码但没有发现哪里有调用
SchemaRegistryClient.register方法的地方,请问它是如何注册schema到confluent schema registry的?