kafka生产者api中的java头信息

stszievb 于 2021-06-06 发布在 Kafka

关注(0)|答案(1)|浏览(639)

我有一个json负载，我想在producerapi中作为头发送

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

以上有效负载应作为标头发送

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

我们怎么做？

Java apache-kafka kafka-producer-api

来源：https://stackoverflow.com/questions/50136040/header-information-in-kafka-producer-api

1条答案

按热度按时间

8qgya5xd1#

有两种方法
1） getheaders和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值、iterable头）
但这样你就得决定分区不

赞(0）回复(0）举报 2021-06-07

我来回答

kafka生产者api中的java头信息

1条答案

相关问题

热门标签

最新问答