This processor executes an Apache Flume source. Each Flume Event is turned into a FlowFile. The content of the FlowFile is set to the body of the Event and the Event headers become FlowFile attributes.
This processor is designed to execute arbitrary Flume sources. Most of the details of configuring the source is deferred to Flume's built-in configuration system. For details on the available settings for each source type, refer to the Flume User Guide. Configuring the Flume source is a four step process:
tier1
tier1
, then the Source Name
is the value of the tier1.sources
property. Example: src-1
tier1.sources.src-1
.
Do not copy the tier1.sources.src-1.type
or
tier1.sources.src-1.channel
properties.
Assuming you had the following existing Flume configuration file:
a1.sources = r1 a1.sinks = k1 a1.channels = c1 a1.sources.r1.type = multiport_syslogtcp a1.sources.r1.channels = c1 a1.sources.r1.host = 0.0.0.0 a1.sources.r1.ports = 10001 10002 10003 a1.sources.r1.portHeader = port a1.sinks.k1.type = logger a1.channels.c1.type = memory a1.channels.c1.capacity = 1000 a1.channels.c1.transactionCapacity = 100 a1.sources.r1.channels = c1 a1.sinks.k1.channel = c1
Then you'd configure the ExecuteFlumeSource as follows:
Property | Value |
---|---|
Source Type | multiport_syslogtcp |
Agent Name | a1 |
Source Name | r1 |
Flume Configuration |
a1.sources.r1.host = 0.0.0.0
|