lalalaYu

我尝试实现DebeziumDeserializationSchema， 在deserialize 重载方法中获取keys ，按照Canal format 在payload嵌入pkNames，然后使用paimon的kafka_sync_database可以实现从Debezium-json获得主键建表 ` @Override public void deserialize(SourceRecord record, Collector out) throws Exception { if (this.jsonConverter == null) { this.initializeJsonConverter(); } byte[] bytes = this.jsonConverter.fromConnectData(record.topic(), record.valueSchema(), record.value());...