问题描述
我有一个方案，其中我的脉冲星窗口函数应调用指定的间隔并将消息发布到输出主题。然后脉冲星接收器将启动并进一步处理到postgres db。
注意：在这里，我已为脉冲星接收器输入主题上载了Json模式。
注意：因此，当单独测试脉冲星接收器时，它可以在json模式下正常工作
注意：但是在生成脉冲星函数输入主题时，它仅接受String，Integer...。在发布到输出主题之前，我需要将其转换为Jsonschema。
请就此分享您的想法。
解决方法
暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！
如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@）