Kafka生产者API中的标头信息 [英] Header information in kafka producer API

问题描述

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

I have a json payload which i want to send as header in producer Api

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

上述有效载荷应作为标头发送

Above payload should be sent as header

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

我们如何做到这一点?

推荐答案

有两种方法

1) getHeaders并添加Header

1) getHeaders and add Header

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

2) use ProducerRecord(String topic, Integer partition, K key, V value, Iterable headers)

但是用这种方法，您必须确定分区号

but this way you have to decide the partition-no

这篇关于Kafka生产者API中的标头信息的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！