A C G I K L O P S

A

addAll(Headers, Headers) - 类 中的静态方法io.github.changebooks.kafka.KafkaHeaders

合并标头

addAll(Headers, Headers) - 类 中的静态方法io.github.changebooks.kafka.KafkaHeaders

合并标头

addProducer(ProducerRecord<K, V>, Headers) - 类 中的静态方法io.github.changebooks.kafka.KafkaHeaders

新增请求标头

addProducer(ProducerRecord<K, V>, Headers) - 类 中的静态方法io.github.changebooks.kafka.KafkaHeaders

新增请求标头

C

close() - 类 中的方法io.github.changebooks.kafka.LogConsumerInterceptor

close() - 类 中的方法io.github.changebooks.kafka.LogConsumerInterceptor

close() - 类 中的方法io.github.changebooks.kafka.LogProducerInterceptor

close() - 类 中的方法io.github.changebooks.kafka.LogProducerInterceptor

configure(Map<String, ?>) - 类 中的方法io.github.changebooks.kafka.LogConsumerInterceptor

configure(Map<String, ?>) - 类 中的方法io.github.changebooks.kafka.LogConsumerInterceptor

configure(Map<String, ?>) - 类 中的方法io.github.changebooks.kafka.LogProducerInterceptor

configure(Map<String, ?>) - 类 中的方法io.github.changebooks.kafka.LogProducerInterceptor

G

get(Headers, String) - 类 中的静态方法io.github.changebooks.kafka.KafkaHeaders

获取一个记录

get(Headers, String) - 类 中的静态方法io.github.changebooks.kafka.KafkaHeaders

获取一个记录

getConsumer(ConsumerRecords<K, V>) - 类 中的静态方法io.github.changebooks.kafka.KafkaHeaders

获取响应标头

getConsumer(ConsumerRecords<K, V>) - 类 中的静态方法io.github.changebooks.kafka.KafkaHeaders

获取响应标头

I

io.github.changebooks.kafka - 程序包 io.github.changebooks.kafka

K

KafkaHeaders - io.github.changebooks.kafka中的类

标头

KafkaHeaders - io.github.changebooks.kafka中的类

标头

KafkaLogId - io.github.changebooks.kafka中的类

日志id

KafkaLogId - io.github.changebooks.kafka中的类

日志id

KafkaTraceId - io.github.changebooks.kafka中的类

追溯id

KafkaTraceId - io.github.changebooks.kafka中的类

追溯id

KEY_NAME - 类 中的静态变量io.github.changebooks.kafka.KafkaLogId

键名

KEY_NAME - 类 中的静态变量io.github.changebooks.kafka.KafkaLogId

键名

KEY_NAME - 类 中的静态变量io.github.changebooks.kafka.KafkaTraceId

键名

KEY_NAME - 类 中的静态变量io.github.changebooks.kafka.KafkaTraceId

键名

L

LogConsumerInterceptor<K,V> - io.github.changebooks.kafka中的类

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

LogConsumerInterceptor<K,V> - io.github.changebooks.kafka中的类

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

LogConsumerInterceptor() - 类 的构造器io.github.changebooks.kafka.LogConsumerInterceptor

LogConsumerInterceptor() - 类 的构造器io.github.changebooks.kafka.LogConsumerInterceptor

LogProducerInterceptor<K,V> - io.github.changebooks.kafka中的类

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

LogProducerInterceptor<K,V> - io.github.changebooks.kafka中的类

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

LogProducerInterceptor() - 类 的构造器io.github.changebooks.kafka.LogProducerInterceptor

LogProducerInterceptor() - 类 的构造器io.github.changebooks.kafka.LogProducerInterceptor

O

onAcknowledgement(RecordMetadata, Exception) - 类 中的方法io.github.changebooks.kafka.LogProducerInterceptor

onAcknowledgement(RecordMetadata, Exception) - 类 中的方法io.github.changebooks.kafka.LogProducerInterceptor

onCommit(Map<TopicPartition, OffsetAndMetadata>) - 类 中的方法io.github.changebooks.kafka.LogConsumerInterceptor

onCommit(Map<TopicPartition, OffsetAndMetadata>) - 类 中的方法io.github.changebooks.kafka.LogConsumerInterceptor

onConsume(Headers) - 类 中的静态方法io.github.changebooks.kafka.KafkaLogId

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

onConsume(Headers) - 类 中的静态方法io.github.changebooks.kafka.KafkaLogId

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

onConsume(Headers) - 类 中的静态方法io.github.changebooks.kafka.KafkaTraceId

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

onConsume(Headers) - 类 中的静态方法io.github.changebooks.kafka.KafkaTraceId

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

onConsume(ConsumerRecords<K, V>) - 类 中的方法io.github.changebooks.kafka.LogConsumerInterceptor

onConsume(ConsumerRecords<K, V>) - 类 中的方法io.github.changebooks.kafka.LogConsumerInterceptor

onSend(Headers) - 类 中的静态方法io.github.changebooks.kafka.KafkaLogId

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

onSend(Headers) - 类 中的静态方法io.github.changebooks.kafka.KafkaLogId

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

onSend(Headers) - 类 中的静态方法io.github.changebooks.kafka.KafkaTraceId

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

onSend(Headers) - 类 中的静态方法io.github.changebooks.kafka.KafkaTraceId

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

onSend(ProducerRecord<K, V>) - 类 中的方法io.github.changebooks.kafka.LogProducerInterceptor

onSend(ProducerRecord<K, V>) - 类 中的方法io.github.changebooks.kafka.LogProducerInterceptor

P

processLog(ConsumerRecords<K, V>) - 类 中的方法io.github.changebooks.kafka.LogConsumerInterceptor

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

processLog(ConsumerRecords<K, V>) - 类 中的方法io.github.changebooks.kafka.LogConsumerInterceptor

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

processLog(ProducerRecord<K, V>) - 类 中的方法io.github.changebooks.kafka.LogProducerInterceptor

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

processLog(ProducerRecord<K, V>) - 类 中的方法io.github.changebooks.kafka.LogProducerInterceptor

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

S

set(Headers, String, String) - 类 中的静态方法io.github.changebooks.kafka.KafkaHeaders

设置一个记录

set(Headers, String, String) - 类 中的静态方法io.github.changebooks.kafka.KafkaHeaders

设置一个记录

A C G I K L O P S