Какая польза от Header в API процессора Kafka?

Question

Я изучаю API процессора Kafka и нахожу заголовки одного метода в ProcessorContext.

headers​()

Возвращает заголовки текущей входной записи; может быть нулевым, если он недоступен

Какая польза от этого метода?

В документах записана только одна строка:

Возвращает заголовки текущей входной записи; может быть нулевым, если он недоступен

Могу ли я выполнить какую-либо операцию над этим, как добавить?

Answer 1

Заголовок - это своего рода метаданные, которые можно добавлять к каждому сообщению. Заголовки могут использоваться в различных сценариях ios, таких как добавление информации, которая может использоваться при фильтрации записей и т. Д. c.

---

Вы можете получить доступ к метаданным сообщений через Processor API, а точнее process(), transform() и transformValues(). Для примера , чтобы добавить заголовок к записи, нужно сделать следующее:

public void process(String key, String value) {

    // add a header to the elements
    context().headers().add.("key", "value")
}