流数据转化为json

[小昌同学]

你好，请问一下上游的数据是
SingleOutputStreamOperator<InPutInfo> outPutInfoStream = 
keyedStream.process(new KeyStreamFunc());
数据样式为：InPutInfo[phone='123456',workId='001']
我想直接将这个流输入到kafka中，直接使用addsink算子，但是查看kafka日志发现，数据内容没有插入进来，想请教一下有没有什么解决方案；
我现在自己想着将流中的数据转换为json，但是我使用了gson以及fastjson都不行，请各位大佬指点
| |
小昌同学
|
|
ccc0606fight...@163.com
|