io.github.changebooks.kafka

类 LogProducerInterceptor<K,V>

java.lang.Object

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

类型参数:

K - Key

V - Value

所有已实现的接口:

org.apache.kafka.clients.producer.ProducerInterceptor<K,V>, org.apache.kafka.common.Configurable

public class LogProducerInterceptor<K,V>
extends Object
implements org.apache.kafka.clients.producer.ProducerInterceptor<K,V>

拦截发送消息 从日志上下文获取日志信息，设置待发送消息

作者:

changebooks@qq.com

构造器概要

构造器

构造器和说明
LogProducerInterceptor()

方法概要

限定符和类型	方法和说明
void	close()
void	configure(Map<String,?> configs)
void	onAcknowledgement(org.apache.kafka.clients.producer.RecordMetadata metadata, Exception exception)
org.apache.kafka.clients.producer.ProducerRecord<K,V>	onSend(org.apache.kafka.clients.producer.ProducerRecord<K,V> rawRecord)
org.apache.kafka.clients.producer.ProducerRecord<K,V>	processLog(org.apache.kafka.clients.producer.ProducerRecord<K,V> record) 发送之前 从日志上下文获取日志信息，设置待发送消息

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

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

构造器详细资料

LogProducerInterceptor

public LogProducerInterceptor()

方法详细资料

onSend

public org.apache.kafka.clients.producer.ProducerRecord<K,V> onSend(org.apache.kafka.clients.producer.ProducerRecord<K,V> rawRecord)

指定者:

onSend 在接口中 org.apache.kafka.clients.producer.ProducerInterceptor<K,V>

processLog

public org.apache.kafka.clients.producer.ProducerRecord<K,V> processLog(org.apache.kafka.clients.producer.ProducerRecord<K,V> record)

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

参数:

record - 待发送的消息

返回:

新的待发送消息，包含日志信息

onAcknowledgement

public void onAcknowledgement(org.apache.kafka.clients.producer.RecordMetadata metadata,
                              Exception exception)

指定者:

onAcknowledgement 在接口中 org.apache.kafka.clients.producer.ProducerInterceptor<K,V>

close

public void close()

指定者:

close 在接口中 org.apache.kafka.clients.producer.ProducerInterceptor<K,V>

configure

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

指定者:

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