Могут ли потоки Kafka отправлять заголовки в тему вывода

У меня есть POJO "Транзакция", как показано ниже:->

  public class Transaction{
    private Meta meta;
    public Headers toHeaders(){
        //convert meta into Kakfa headers and return
    }
}

Я хочу отправить эти заголовки в тему вывода моего приложения Kafka streams, но я не смог найти способ сделать это. Существует нечто, называемое ExtendedSerializer, которое берет заголовки, но я не хочу включать заголовки как часть полезной нагрузки ключа или значения.

Есть ли способ отправить заголовки в тему вывода потоков kafka?

0 ответов

Другие вопросы по тегам