io.github.changebooks.kafka

类 LogConsumerInterceptor<K,V>

java.lang.Object

io.github.changebooks.kafka.LogConsumerInterceptor<K,V>

类型参数:

K - Key

V - Value

所有已实现的接口:

AutoCloseable, org.apache.kafka.clients.consumer.ConsumerInterceptor<K,V>, org.apache.kafka.common.Configurable

public class LogConsumerInterceptor<K,V>
extends Object
implements org.apache.kafka.clients.consumer.ConsumerInterceptor<K,V>

拦截接收消息 从已接收消息获取日志信息，设置日志上下文

作者:

changebooks@qq.com

构造器概要

构造器

构造器和说明
LogConsumerInterceptor()

方法概要

限定符和类型	方法和说明
void	close()
void	configure(Map<String,?> configs)
void	onCommit(Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> offsets)
org.apache.kafka.clients.consumer.ConsumerRecords<K,V>	onConsume(org.apache.kafka.clients.consumer.ConsumerRecords<K,V> records)
void	processLog(org.apache.kafka.clients.consumer.ConsumerRecords<K,V> records) 消费之前 从已接收消息获取日志信息，设置日志上下文

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

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

构造器详细资料

LogConsumerInterceptor

public LogConsumerInterceptor()

方法详细资料

onConsume

public org.apache.kafka.clients.consumer.ConsumerRecords<K,V> onConsume(org.apache.kafka.clients.consumer.ConsumerRecords<K,V> records)

指定者:

onConsume 在接口中 org.apache.kafka.clients.consumer.ConsumerInterceptor<K,V>

processLog

public void processLog(org.apache.kafka.clients.consumer.ConsumerRecords<K,V> records)

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

参数:

records - 已接收的消息

onCommit

public void onCommit(Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> offsets)

指定者:

onCommit 在接口中 org.apache.kafka.clients.consumer.ConsumerInterceptor<K,V>

close

public void close()

指定者:

close 在接口中 AutoCloseable

指定者:

close 在接口中 org.apache.kafka.clients.consumer.ConsumerInterceptor<K,V>

configure

public void configure(Map<String,?> configs)

指定者:

configure 在接口中 org.apache.kafka.common.Configurable