Welcome to the Cloudera Community

Announcements
Celebrating as our community reaches 100,000 members! Thank you!

Who agreed with this topic

Flume use of multiplexing channel selector - Clarification Needed

avatar
Champion

Below configuration, I am using multiplexing channel selector with header as State and mapping is made to OH, NY, IN . 

 

I would like to know how one could include event header in the flume configuration. I am aware of static interceptor but static interceptor will include the header key value for all the event in my senario it wont suit . please guide me on this . 

 

spoolDirAgent.sources.source1.selector.type = multiplexing
spoolDirAgent.sources.source1.selector.header = State
spoolDirAgent.sources.source1.selector.mapping.OH = channel1
spoolDirAgent.sources.source1.selector.mapping.NY = channel2
spoolDirAgent.sources.source1.selector.mapping.IN = channel2
spoolDirAgent.sources.source1.selector.defalut = channel1

Any information is higly appreciatable. 

Who agreed with this topic