Flink MySQL CDC 注册 schema registry 问题

Fri, 22 Apr 2022 18:03:15 -0700 

Hi, 我想使用 Flink MySQL CDC Connector 以 DataStream 方式消费 MySQL Binlog 
输出变更数据到下游kafka topic (1)，同时监听database schema change事件，将最新的schema数据输出到下游另一个kafka 
topic (2)，又或者直接注册schema到 confluent / apicurio schema registry，查了一下flink 
cdc官方文档[1]，并没有这方面的信息。请问应该怎么实现呢？有相关文档或例子么？谢谢！


[1] 
https://ververica.github.io/flink-cdc-connectors/master/content/connectors/mysql-cdc.html

回复