K - KeyV - Valuepublic class LogConsumerInterceptor<K,V> extends Object implements org.apache.kafka.clients.consumer.ConsumerInterceptor<K,V>
| 构造器和说明 |
|---|
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)
消费之前
从已接收消息获取日志信息,设置日志上下文
|
public org.apache.kafka.clients.consumer.ConsumerRecords<K,V> onConsume(org.apache.kafka.clients.consumer.ConsumerRecords<K,V> records)
public void processLog(org.apache.kafka.clients.consumer.ConsumerRecords<K,V> records)
records - 已接收的消息public void onCommit(Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> offsets)
public void close()
close 在接口中 AutoCloseableclose 在接口中 org.apache.kafka.clients.consumer.ConsumerInterceptor<K,V>Copyright © 2023. All rights reserved.