文件名称:flume-logstash-sink:Flume sink 使用 logstash V2 格式将日志事件发送到 ES 集群
文件大小:10KB
文件格式:ZIP
更新时间:2024-07-27 07:28:24
Java
水槽-logstash-sink Flume sink 使用 logstash V2 格式将日志事件发送到 ES 集群 看到 要启用事件序列化器,您需要将此行添加到水槽接收器配置中: [agent_name].sinks.[sink_name].indexNameBuilder = com.gilt.flume.elasticsearch.TimeBasedIndexNameBuilderV12 并设置序列化程序: [agent_name].sinks.[sink_name].serializer = com.gilt.flume.elasticsearch.ElasticSearchLogStashEventSerializerV12 您还需要将 jar 添加到您的水槽 lib 文件夹中,以便可以访问这些类。
【文件预览】:
flume-logstash-sink-master
----src()
--------main()
----LICENSE(11KB)
----README.md(660B)
----pom.xml(2KB)
----.gitignore(97B)