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