Re: flink api消费kafka（avro）数据出错

Hi 看着是解析数据错误，可以检查一下是不是source的schema和数据不匹配 On Tue, Apr 18, 2023 at 2:46 PM kcz <573693...@qq.com.invalid> wrote: > 版本：1.15.2 >1.首先是采用SQL方式，将json数据输入到kafka里面（avro格式） >2.然后采用DS api方式去接收解析kafka里面的avro数据 > --报错如下-- >

flink api??????

flink??api?? 1.connectkeyedstream??key join?? 2.coprocessfunction ?? keyedcoprocessfunction