Flume использование мультиплексного селектора каналов

Question

Flume использование мультиплексного селектора каналов

Я пытаюсь реализовать flume для приема данных около 1 ТБ. Для этого я пытаюсь использовать селектор каналов мультиплексирования.

Есть несколько примеров, показывающих, как использовать селектор мультиплексного канала.

У меня вопрос, как можно определить содержание заголовка события?

Например, в приведенной ниже конфигурации я использую селектор канала мультиплексирования с заголовком в качестве состояния и выполняется сопоставление с CN, ID, IN и т. Д.

spoolDirAgent.sources.source1.selector.type = multiplexing
spoolDirAgent.sources.source1.selector.header = State
spoolDirAgent.sources.source1.selector.mapping.CN = channel1
spoolDirAgent.sources.source1.selector.mapping.IN = channel2
spoolDirAgent.sources.source1.selector.mapping.ID = channel2
spoolDirAgent.sources.source1.selector.defalut = channel1

Также, если возможно, пожалуйста, дайте мне знать, как использовать заголовки событий в источниках потока?

Заранее спасибо!

1

flume multiplexing

Источник

user2409190 30 июл '13 в 10:36

1 ответ

Решение

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

user157300 30 окт '13 в 05:53 2013-10-30 05:53 · Accepted Answer · 2013-10-30 05:53

Как указано в руководстве пользователя flume-ng, если заголовок события не содержит ключа "State", будет использоваться канал по умолчанию. и искать "статический перехватчик" в руководстве пользователя flume-ng, тогда вы более или менее узнаете, как добавить ключ "State" в заголовок.