flume-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Andre <andre-li...@fucs.org>
Subject Using dots on agent1.sources.r1.selector.mapping
Date Tue, 27 Oct 2015 09:54:28 GMT
Hi there,

I am testing flume as part of a kafka pipeline and struggling to get
two particular pieces of the puzzle together...

In my config I have:


agent1.sources.r1.interceptors = i1
agent1.sources.r1.interceptors.i1.type = regex_extractor
agent1.sources.r1.interceptors.i1.regex = ([^\\s]+)
agent1.sources.r1.interceptors.i1.serializers = ip_address
agent1.sources.r1.interceptors.i1.serializers.ip_address.name = key

agent1.sources.r1.selector.type = multiplexing
agent1.sources.r1.selector.header = key
agent1.sources.r1.selector.mapping.10.11.12.13 = ch1
agent1.sources.r1.selector.default = ch2

where 10.11.12.13 is the IP address of a machine whose data should
flow via ch1 (a Kafka sink).

Upon starting the agent I can see all sinks starting, however, all
traffic seems to go via ch2 (as if no value of matched 10.11.12.13).

Could someone clarify if it is possible to use dots in the
selector.mapping property and if yes, with what syntax?

Best regards

Mime
View raw message