перенаправлять сообщения JMS на основе свойства в сообщении с использованием Flume

Мы настроили Flume для чтения сообщений JMS из системы, и это работает нормально.

Теперь я хотел бы прочитать сообщение и перенаправить его в несколько мест на основе свойства в сообщении.

Пример: если мое текстовое сообщение выглядит так: TextMessage ={Header={....} Properties ={type = {String:dest1}....}

Я хочу перенаправить это сообщение в /path/to/base/dir/dest1

аналогично, если мое сообщение TextMessage = {Header={....} Properties ={type = {String:dest2}....}

мой пункт назначения должен быть /path/to/base/dir/dest2

Я не уверен, можно ли этого добиться с помощью перехватчиков. Если да, пожалуйста, направьте меня


hadoop jms cloudera-cdh flume
person Praveen Kumar Chalamcharla    schedule 16.10.2014    source источник

Ответы (1)


arrow_upward
0
arrow_downward

Я считаю, что вам нужно определить мультиплексор потока.

person andreadi    schedule 16.10.2014
comment
Я очень новичок в Flume и JMS. Не могли бы вы направить меня к примеру мультиплексирования Flume или к определению мультиплексора для перенаправления на основе свойства сообщения - person Praveen Kumar Chalamcharla; 16.10.2014