io.github.changebooks.kafka

类 KafkaHeaders

java.lang.Object

io.github.changebooks.kafka.KafkaHeaders

public final class KafkaHeaders
extends Object

标头

作者:

changebooks@qq.com

方法概要

限定符和类型	方法和说明
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) 设置一个记录

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

方法详细资料

getConsumer

public static <K,V> org.apache.kafka.common.header.Headers getConsumer(org.apache.kafka.clients.consumer.ConsumerRecords<K,V> records)

获取响应标头

类型参数:

K - Key

V - Value

参数:

records - 接收消息集

返回:

响应标头

addProducer

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 - Key

V - Value

参数:

record - 发送消息

headers - 请求标头

返回:

新的发送消息，包含请求标头

get

public static String get(org.apache.kafka.common.header.Headers headers,
                         String key)

获取一个记录

参数:

headers - 标头

key - 键名

返回:

最近新增的一个记录

set

public static org.apache.kafka.common.header.Headers set(org.apache.kafka.common.header.Headers headers,
                                                         String key,
                                                         String value)

设置一个记录

参数:

headers - 标头

key - 键名

value - 记录，空？忽略

返回:

标头

addAll

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 - 待合并的标头

返回:

合并后的标头