hadoop - 使用flume根据消息中的属性重定向JMS消息

Question

我们已经将Flume配置为从系统读取JMS消息，并且工作正常。

现在，我想阅读消息并根据消息中的属性将其重定向到多个位置。

例:
如果我的TextMessage看起来像:TextMessage = {Header = {....} Properties = {type = {String:dest1} ....}

我想将此消息重定向到/ path / to / base / dir / dest1

类似地，如果我的消息TextMessage = {Header = {....}属性= {type = {String:dest2} ....}

我的目的地应该是/ path / to / base / dir / dest2

我不确定是否可以通过使用拦截器来实现。如果可以，请指导我

Answer 1

我相信您需要定义一个流多路复用器。