被拦截器拦截前重复通道

Question

我用水槽做了这样的事

Source --> interceptor --> Channel --> multiplexing --> HDFS Sink
                                          |-----------> Null Sink

我想在源后面添加一个通道，但我不希望事件通过拦截器。我想要“生”事件。如下所示：

Source --> interceptor (i) --> Channel --> multiplexing --> HDFS Sink
    |                                     |-----------> Null Sink
    |-------> Channel (must no be intercepted by i) --> HDFS

我该怎么做呢？

谢谢

Answer 1

由于每个源都配置了拦截器，所以必须添加第二个源(配置时根本没有拦截器，并在不同的Http端口中侦听)，并两次发出数据:一个副本用于带有拦截器的源，另一个副本为另一个源。

另一种可能是连锁两名特工。第一个源包含一个没有拦截器的源，和两个接收器:一个用于像HDFS中那样持久化数据，另一个提供您已经拥有的代理。我是说：

src-->ch-->multip-->sink----------->src-->int-->ch-->multip-->hdfssink
                |-->hdfssink                              |-->nullsink
(________agent1____________)        (_____________agent2_____________)