本次代码主要侧重为flink stream流解析cannal-json，经过多次实验，发现还是阿里的fastjson较为好用，故在此做记录 将依赖引入 <dependency><groupId>com.alibaba</groupId><artifactId>fastjson</artifactId&g...