我使用debezium嵌入式连接器来侦听数据库中的变化。它给了我一个ChangeEvent<SourceRecord,SourceRecord>对象
我想进一步使用融合插件KCBQ，它使用SinkRecord将数据放入bigquery。但是我不知道如何把这两部分连接起来。
最后，我如何确保MySQL的更新，删除和模式更改从Embedded Debezium传播到BigQuery
如果必须使用任何自定义转换，则可能必须使用单个消息转换。然而对于这个场景,因为这似乎是一种常用的变换,提取新的状态转换似乎成就这事。也许值得一看，并尝试类似的
https://issues.redhat.com/browse/dbz - 226
https://issues.redhat.com/browse/dbz - 1896