Elasticsearch 序列化程序接受 JSON 字符串作为文档

Question

我的应用程序需要写入 Flume 并且 flume 将请求转发给 Elasticsearch。我还没有想出如何接受数据作为 json 字符串，以便 flume 围绕它构建一个文档并索引到 Elasticsearch。

我尝试将 netcat 作为源，但随后它创建了一个包含字段主体的文档并将我的字符串 JSON 放入其中。 我宁愿期望它通过反序列化 JSON 字符串来创建文档。

Answer 1

即将发布的 Flume 1.6 版本对此有更好的支持。

或者，编写您自己的序列化程序。