Apache Flume с двумя разными перехватчиками на одном источнике

Я пытаюсь добавить 2 разных перехватчика к одному источнику и отправить перехваченные данные на 2 разных канала. Но я не смог настроить то же самое. Не удалось найти документации о том же. Кроме того, у меня возникли проблемы с переключателями каналов. Не знаю, как выбрать канал с разными перехватчиками.

Вот мой код:

a1.sources = syslog_udp
a1.channels = chan1 chan2
a1.sinks = sink1 sink2 //both are different kafka sinks


a1.sources.syslog_udp.type = syslogudp
a1.sources.syslog_udp.port = 514
a1.sources.syslog_udp.host = 0.0.0.0
a1.sources.syslog_udp.keepFields = true

a1.sources.syslog_udp.interceptors = i1 i2
a1.sources.syslog_udp.interceptors.i1.type = regex_filter
a1.sources.syslog_udp.interceptors.i1.regex = '<regex_string1>'
a1.sources.syslog_udp.interceptors.i1.excludeEvents = false

a1.sources.syslog_udp.interceptors.i2.type = regex_filter
a1.sources.syslog_udp.interceptors.i2.regex = '<regex_string1>'|'<regex_string2>'
a1.sources.syslog_udp.interceptors.i2.excludeEvents = false

a1.sources.syslog_udp.selector.type = multiplexing
a1.sources.syslog_udp.channels = chan1 chan2


a1.channels.chan1.type = memory
a1.channels.chan1.capacity = 200
a1.channels.chan2.type = memory
a1.channels.chan2.capacity = 200
Как установить LAMP Stack 1/2 на Azure Linux VM
Как установить LAMP Stack 1/2 на Azure Linux VM
В дополнение к нашему предыдущему сообщению о намерении Azure прекратить поддержку Azure Database для MySQL в качестве единого сервера после 16...
0
0
226
1
Перейти к ответу Данный вопрос помечен как решенный

Ответы 1

Ответ принят как подходящий

Похоже, для этого не существует простой настройки. Обход этого типа компоновки состоит в том, чтобы иметь перехватчик с одним / более широким каналом в одном агенте, направлять вывод в avro-приемник и настраивать новый агент для avro-источника и настраивать новый перехватчик каналов на этом. .

Другие вопросы по теме