当我在接收器连接器上应用jsonConverter时，Json消息正在转换

Question

我在kafka中有类似Json的消息{"name":"abc"}当我为fileStream接收器连接器应用带有Json转换器的接收器连接器时，我得到的消息如下{name=abc}这是不正确的Json。我试过简单的字符串连接器，但没有区别。有人能帮我做这个吗。我想要文件中的消息

Answer 1

FileStreamSink始终将Connect Struct写入字符串输出，不用于生产用例。

它不支持format.class=JSONFormat，例如S3或HDFS接收器。

作为一种变通方法，您可以将Minio作为S3的替代品运行，也可以完全使用不同的接收器连接器，这取决于您实际想要对这些数据做什么。例如，Mongo或JDBC接收器，它们分别提供自己的导出工具，并且可以比平面文件更快地搜索/分析数据。