文件名称：flume-ng-extends-sink:几个水槽的水槽
文件大小：20KB
文件格式：ZIP
更新时间：2024-07-02 07:21:31
Java
flume-ng-extends-sink several flume NG sinks: Advanced logger sink, Kafka sink, etc. AdvancedLoggerSink: KafkaSink: ElasticSearchSink：定制Serializer，elasticsearch.serializer.* ##组件版本 工程中，涉及到的组件版本，见下表： 组件 版本 Flume NG 1.5.2 ##预装环境 编译工程前，需要预装环境： JDK 1.6+ ##AdvancedLoggerSink 背景：LoggerSink只在log中输出Event的前16 bytes的内容。 目标：实现Event输出bytes个数的可配置； 思路：基于org.apache.flume.sink.LoggerSink扩展，指定bytes个数的参数； ###配置示例 使
【文件预览】：
flume-ng-extends-sink-master
----src()
--------main()
----LICENSE(1KB)
----README.md(4KB)
----pom.xml(2KB)
----.gitignore(43B)