У меня есть http-сервер, записывающий файлы журналов, которые я затем загружаю в HDFS с помощью Flume. Сначала я хочу отфильтровать данные в соответствии с данными, которые есть в моем заголовке или теле. Я прочитал, что я могу сделать это, используя перехватчик с регулярным выражением, кто-то может объяснить, что именно мне нужно сделать? Нужно ли мне писать код Java, который переопределяет код Flume?

Также я хотел бы взять данные и в соответствии с заголовком отправить их в другой приемник (т.е. источник = 1 отправляется в приемник1, а источник = 2 - в приемник2), как это делается?

благодарю вас,

Шимон