1

我正在尝试实施水槽来摄取大约 1TB 的数据。为此，我尝试使用多路复用通道选择器。

有一些可用的示例展示了如何使用多路复用通道选择器。

我的问题是如何确定事件的标题内容？

例如，在下面的配置中，我使用多路复用通道选择器，将标头作为状态，并映射到 CN、ID、IN 等。

spoolDirAgent.sources.source1.selector.type = multiplexing
spoolDirAgent.sources.source1.selector.header = State
spoolDirAgent.sources.source1.selector.mapping.CN = channel1
spoolDirAgent.sources.source1.selector.mapping.IN = channel2
spoolDirAgent.sources.source1.selector.mapping.ID = channel2
spoolDirAgent.sources.source1.selector.defalut = channel1

另外，如果可能的话，请让我知道如何在水槽源中使用事件标头？

提前致谢！

4

1 回答 1

0

正如flume-ng用户指南所指出的，如果事件头不包含键'State'，那么将使用默认通道。并在 flume-ng 用户指南中搜索“静态拦截器”，然后或多或少您将知道如何将键“状态”添加到标题中。

于 2013-10-30T05:53:43.977 回答