io.github.changebooks.kafka

类 KafkaLogId

java.lang.Object

io.github.changebooks.kafka.KafkaLogId

public final class KafkaLogId
extends Object

日志id

作者:

changebooks@qq.com

字段概要

字段

限定符和类型	字段和说明
static String	KEY_NAME 键名

方法概要

限定符和类型	方法和说明
static void	onConsume(org.apache.kafka.common.header.Headers headers) 消费之前 从已接收消息获取日志id，设置日志上下文
static void	onSend(org.apache.kafka.common.header.Headers headers) 发送之前 从日志上下文获取日志id，设置待发送消息

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

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

字段详细资料

KEY_NAME

public static final String KEY_NAME

键名

另请参阅:

常量字段值

方法详细资料

onConsume

public static void onConsume(org.apache.kafka.common.header.Headers headers)

消费之前 从已接收消息获取日志id，设置日志上下文

参数:

headers - 已接收消息的标头

onSend

public static void onSend(org.apache.kafka.common.header.Headers headers)

发送之前 从日志上下文获取日志id，设置待发送消息

参数:

headers - 待发送的消息的标头