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

Question

Я пытаюсь реализовать лоток для сбора данных около 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 

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

Заранее благодарен!

Answer 1

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