java - kafka生产者API中的头信息

Question

我有一个 json 有效负载，我想将其作为生产者 Api 中的 header 发送

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

以上有效负载应作为 header 发送

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 值，可迭代 header )

但是这样你就必须决定分区号