public final class KafkaHeaders extends Object
| 限定符和类型 | 方法和说明 |
|---|---|
static org.apache.kafka.common.header.Headers |
addAll(org.apache.kafka.common.header.Headers headers,
org.apache.kafka.common.header.Headers others)
合并标头
|
static <K,V> org.apache.kafka.clients.producer.ProducerRecord<K,V> |
addProducer(org.apache.kafka.clients.producer.ProducerRecord<K,V> record,
org.apache.kafka.common.header.Headers headers)
新增请求标头
|
static String |
get(org.apache.kafka.common.header.Headers headers,
String key)
获取一个记录
|
static <K,V> org.apache.kafka.common.header.Headers |
getConsumer(org.apache.kafka.clients.consumer.ConsumerRecords<K,V> records)
获取响应标头
|
static org.apache.kafka.common.header.Headers |
set(org.apache.kafka.common.header.Headers headers,
String key,
String value)
设置一个记录
|
public static <K,V> org.apache.kafka.common.header.Headers getConsumer(org.apache.kafka.clients.consumer.ConsumerRecords<K,V> records)
K - KeyV - Valuerecords - 接收消息集public static <K,V> org.apache.kafka.clients.producer.ProducerRecord<K,V> addProducer(org.apache.kafka.clients.producer.ProducerRecord<K,V> record,
org.apache.kafka.common.header.Headers headers)
K - KeyV - Valuerecord - 发送消息headers - 请求标头public static String get(org.apache.kafka.common.header.Headers headers, String key)
headers - 标头key - 键名public static org.apache.kafka.common.header.Headers set(org.apache.kafka.common.header.Headers headers,
String key,
String value)
headers - 标头key - 键名value - 记录,空?忽略public static org.apache.kafka.common.header.Headers addAll(org.apache.kafka.common.header.Headers headers,
org.apache.kafka.common.header.Headers others)
headers - 当前标头others - 待合并的标头Copyright © 2023. All rights reserved.