Hello.

My collector currently has a single collectorSink writing to HDFS. Now
I'd like to add a real time "tap" into flume. The fanout feature seems
suited for this purpose.

However, I would like to do so in such a way that the availability of
the tap node does not affect the writing of data to the HDFS
collectorSink. Basically, I want flume to not care if this node is
down.

Any idea how I can do this? I tried using
[collectorSink("hdfs..."), agentBESink("tap...")]
but agentBESink will block writing to the collectorSink if the tap node is down.

Best regards
Björn

Reply via email to