Я имею дело с такими данными, как: {"a":1,"b":2}
, и я хочу, чтобы Flume добавил заголовок ко всем данным, таким как {"header":self_define,"content":{"a":1,"b":2}}
Я прочитал некоторые материалы о перехватчике Flume, но, похоже, их можно использовать только для изменить выходной путь приемников. Есть ли способ достичь этого, или я должен сам разработать класс перехватчиков?
Любая помощь приветствуется.