Я пытаюсь добавить 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
Похоже, для этого не существует простой настройки. Обход этого типа компоновки состоит в том, чтобы иметь перехватчик с одним / более широким каналом в одном агенте, направлять вывод в avro-приемник и настраивать новый агент для avro-источника и настраивать новый перехватчик каналов на этом. .