FlinkCDC连接tidb乱码

坑爹的地方是因为record.getValue()和record.getKey()不能直接toString解析!

参考一下RowDataTiKVSnapshotEventDeserializationSchema的源码,做一下改造就好了。
Object[] tikvValues =
decodeObjects(
record.getValue().toByteArray(),
RowKey.decode(record.getKey().toByteArray()).getHandle(),
tableInfo);

希望官方能把早点这个问题修复吧!易用性比较差