Flume先复制再过滤,怎么样?

Flume replicate then filter, how?

我需要复制一个源,然后在正则表达式上仅过滤一个副本。

例如,如果我的源数据是 'dog, donkey, cat',我想将 'dog, donkey, cat' 下沉到一个地方,但只下沉 'dog, donkey' 到另一个地方 (d*)。

我打算使用正则表达式拦截器,但我不知道如何执行此操作,因为拦截器与源相关联。这是如何实现的?

必须为此创建另一个 flume 代理层。在当前代理上复制,并转发到新的 flume 代理进程,在那里它可以将正则表达式拦截器附加到源。