Заголовок информации в API производителя кафки

Question

У меня есть полезная нагрузка json, которую я хочу отправить в качестве заголовка в Api производителя

{
    "type": "record_created",
    "version": 1,
    "orgId": "",
    "userId": "",
    "userName": "",
    "correlationId": "",
    "jobId": ""
}

Над полезной нагрузкой должен быть отправлен заголовок

producer.send(new ProducerRecord<Integer, String>(topic, messageNo, records,header)

Как мы можем это сделать?

Answer 1

Есть два способа

1) getHeaders и добавить заголовок

ProducerRecord<Integer, String> record = new ProducerRecord<Integer, String>("topic", 1, "message");
record.headers().add(new RecordHeader("type", "record_created".getBytes()));
record.headers().add(new RecordHeader("type", "record_created".getBytes()));    
producer.send(record);

2) использовать ProducerRecord (строковый раздел, целочисленный раздел, ключ K, значение V, итерируемые заголовки)

но так вы должны решить раздел - нет