You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by "casel.chen" <ca...@126.com> on 2022/04/23 01:02:56 UTC

Flink MySQL CDC 注册 schema registry 问题

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