问答 2023-06-11 来自:开发者社区

请问 Flink CDC 用API 读取kafka 的json记录,下面脚本报序列化报错,是序列?

请问 Flink CDC 用API 读取kafka 的json记录,下面脚本报序列化报错,是序列化写法不对吗 JsonDeserializationSchema jsonFormat=new JsonDeserializationSchema<>(RuleDetail.class); KafkaSource source = KafkaSource.builder() ...

问答 2023-02-06 来自:开发者社区

pyflink 连接kafka 不定字段的json反序列化,有没有比较好的写法?

pyflink 连接kafka 不定字段的json反序列化,有没有比较好的写法?

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

开发与运维

集结各类场景实战经验,助你开发运维畅行无忧

+关注