这个demo非常棒,让人有更多想象。目前我考虑直接查询mysql,需要构造com.alibaba.dts.formats.avro.Record,以期复用已有的消费代码。 我的理解如下: 因为AfterImage的类型是GenericData$Array,所以通过查询mysql数据表记录结果集,把记录fill到这个类型的对象里去。