Hi, 你使用的那个 Flink 版本，建议直接参考 Flink 官方 kafka connector 文档[1]。 转换为 Json 数据格式可以使用 flink-json format
[1] https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/datastream/kafka/#kafka-sink [2] https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/datastream/formats/json/ Best, Weihua On Fri, Apr 14, 2023 at 7:17 PM 小昌同学 <ccc0606fight...@163.com> wrote: > 你好，请问一下上游的数据是 > SingleOutputStreamOperator<InPutInfo> outPutInfoStream = > keyedStream.process(new KeyStreamFunc()); > 数据样式为：InPutInfo[phone='123456',workId='001'] > 我想直接将这个流输入到kafka中，直接使用addsink算子，但是查看kafka日志发现，数据内容没有插入进来，想请教一下有没有什么解决方案； > 我现在自己想着将流中的数据转换为json，但是我使用了gson以及fastjson都不行，请各位大佬指点 > | | > 小昌同学 > | > | > ccc0606fight...@163.com > |
