Блог

Я использую приемник Kafka Connect S3, и он записывает значение записи только в S3. Я хочу включить некоторые заголовки записей в конечную полезную нагрузку, которая записывается в S3.

Как я могу это сделать?

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

В исходном коде Kafka Connect S3 вы можете видеть, что значение записи действительно только записывается.