文件名称：flume-ng-router-sinks
文件大小：124KB
文件格式：ZIP
更新时间：2024-06-08 09:15:35
Java
flume-ng路由器接收器 将flume-ng接收器扩展到类似路由器的接收器，后者可以根据事件的特定标头路由事件。 AvroRouterSink MailRouterSink 与水槽1.4.0、1.5.0、1.5.0.1兼容。 为什么路由器下沉 已经提供了类似路由器的功能。 为什么我们在接收器上需要这样的功能？ 在我们的情况下，我们需要创建一个平面结构，以便在事件吸收到水槽源之后立即实现事件分离功能。 如果仅使用通道选择器，则水槽拓扑将被限制在有限的服务器中。 例如，事件具有两种类型的标题，如下所示： 标头 价值 主持人 {A_host，B_host} 类型 {A_type，B_type} JSON格式的事件 { "header": { "host": "A_host", "type": "B_type" }, "Body": "
【文件预览】：
flume-ng-router-sinks-master
----example()
--------main.conf(2KB)
--------sub_log4j.properties(3KB)
--------chainedAgents.png(286KB)
--------main_log4j.properties(3KB)
--------compactedAgent.png(132KB)
--------RUN(314B)
--------sub.conf(880B)
----pom.xml(2KB)
----flume-ng-avro-router-sink()
--------pom.xml(1KB)
--------src()
----flume-ng-mail-router-sink()
--------pom.xml(1KB)
--------src()
----.gitignore(218B)
----README.md(3KB)