Могут ли потоки Kafka отправлять заголовки в тему вывода
У меня есть POJO "Транзакция", как показано ниже:->
public class Transaction{
private Meta meta;
public Headers toHeaders(){
//convert meta into Kakfa headers and return
}
}
Я хочу отправить эти заголовки в тему вывода моего приложения Kafka streams, но я не смог найти способ сделать это. Существует нечто, называемое ExtendedSerializer, которое берет заголовки, но я не хочу включать заголовки как часть полезной нагрузки ключа или значения.
Есть ли способ отправить заголовки в тему вывода потоков kafka?