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

合并标头

addContext(KafkaContext) - 接口 中的方法io.github.changebooks.kafka.KafkaBatchContext

新增消费上下文

addContext(KafkaContext) - 接口 中的方法io.github.changebooks.kafka.KafkaBatchContext

新增消费上下文

addContext(KafkaContext) - 类 中的方法io.github.changebooks.kafka.KafkaBatchContextImpl

addContext(KafkaContext) - 类 中的方法io.github.changebooks.kafka.KafkaBatchContextImpl

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

新增请求标头

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

新增请求标头

asyncConsume(List<List<ConsumerRecord<String, String>>>, KafkaBatchContext) - 类 中的方法io.github.changebooks.kafka.KafkaBatchListener

多线程消费

asyncConsume(List<List<ConsumerRecord<String, String>>>, KafkaBatchContext) - 类 中的方法io.github.changebooks.kafka.KafkaBatchListener

多线程消费

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

compute(List<T>, int) - 类 中的静态方法io.github.changebooks.kafka.PageUtils

计算分页

compute(List<T>, int) - 类 中的静态方法io.github.changebooks.kafka.PageUtils

计算分页

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

consume(List<ConsumerRecord<String, String>>, KafkaBatchContext) - 接口 中的方法io.github.changebooks.kafka.KafkaBatchConsumer

执行消费

consume(List<ConsumerRecord<String, String>>, KafkaBatchContext) - 接口 中的方法io.github.changebooks.kafka.KafkaBatchConsumer

执行消费

consume(List<ConsumerRecord<String, String>>, KafkaBatchContext) - 类 中的方法io.github.changebooks.kafka.KafkaBatchListener

执行消费

consume(List<ConsumerRecord<String, String>>, KafkaBatchContext) - 类 中的方法io.github.changebooks.kafka.KafkaBatchListener

执行消费

G

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

获取一个记录

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

获取一个记录

getAttribute(String) - 接口 中的方法io.github.changebooks.kafka.KafkaBatchContext

获取一个属性

getAttribute(String) - 接口 中的方法io.github.changebooks.kafka.KafkaBatchContext

获取一个属性

getAttribute(String) - 类 中的方法io.github.changebooks.kafka.KafkaBatchContextImpl

getAttribute(String) - 类 中的方法io.github.changebooks.kafka.KafkaBatchContextImpl

getAttributes() - 接口 中的方法io.github.changebooks.kafka.KafkaBatchContext

获取全部属性

getAttributes() - 接口 中的方法io.github.changebooks.kafka.KafkaBatchContext

获取全部属性

getAttributes() - 类 中的方法io.github.changebooks.kafka.KafkaBatchContextImpl

getAttributes() - 类 中的方法io.github.changebooks.kafka.KafkaBatchContextImpl

getCode() - 类 中的方法io.github.changebooks.kafka.KafkaContext

getCode() - 类 中的方法io.github.changebooks.kafka.KafkaContext

getConsumer() - 类 中的方法io.github.changebooks.kafka.KafkaBatchListener

getConsumer() - 类 中的方法io.github.changebooks.kafka.KafkaBatchListener

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

获取响应标头

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

获取响应标头

getContexts() - 接口 中的方法io.github.changebooks.kafka.KafkaBatchContext

获取全部消费上下文

getContexts() - 接口 中的方法io.github.changebooks.kafka.KafkaBatchContext

获取全部消费上下文

getContexts() - 类 中的方法io.github.changebooks.kafka.KafkaBatchContextImpl

getContexts() - 类 中的方法io.github.changebooks.kafka.KafkaBatchContextImpl

getExecutor() - 类 中的方法io.github.changebooks.kafka.KafkaBatchListener

getExecutor() - 类 中的方法io.github.changebooks.kafka.KafkaBatchListener

getMessage() - 类 中的方法io.github.changebooks.kafka.KafkaContext

getMessage() - 类 中的方法io.github.changebooks.kafka.KafkaContext

getRecord() - 类 中的方法io.github.changebooks.kafka.KafkaContext

getRecord() - 类 中的方法io.github.changebooks.kafka.KafkaContext

getThreadNum() - 类 中的方法io.github.changebooks.kafka.KafkaBatchListener

getThreadNum() - 类 中的方法io.github.changebooks.kafka.KafkaBatchListener

I

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

isSuccess() - 类 中的方法io.github.changebooks.kafka.KafkaContext

isSuccess() - 类 中的方法io.github.changebooks.kafka.KafkaContext

K

KafkaBatchConsumer - io.github.changebooks.kafka中的接口

批量消费

KafkaBatchConsumer - io.github.changebooks.kafka中的接口

批量消费

KafkaBatchContext - io.github.changebooks.kafka中的接口

批量消费上下文

KafkaBatchContext - io.github.changebooks.kafka中的接口

批量消费上下文

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

批量消费上下文的默认实现

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

批量消费上下文的默认实现

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

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

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

消息分页，并行消费 总行数 / 线程数 = 每线程处理行数 可以整除时，线程数 == 实际线程数，如：总行数 = 9 和 线程数 = 3，实际结果：实际线程数 = 3，每线程处理行数 = 3 不能整除时，线程数 !

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

消息分页，并行消费 总行数 / 线程数 = 每线程处理行数 可以整除时，线程数 == 实际线程数，如：总行数 = 9 和 线程数 = 3，实际结果：实际线程数 = 3，每线程处理行数 = 3 不能整除时，线程数 !

KafkaBatchListener(Executor, KafkaBatchConsumer) - 类 的构造器io.github.changebooks.kafka.KafkaBatchListener

KafkaBatchListener(Executor, KafkaBatchConsumer) - 类 的构造器io.github.changebooks.kafka.KafkaBatchListener

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

消费上下文

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

消费上下文

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

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

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

listen(List<ConsumerRecord<String, String>>, KafkaBatchContext) - 类 中的方法io.github.changebooks.kafka.KafkaBatchListener

计算分页，多线程消费

listen(List<ConsumerRecord<String, String>>, KafkaBatchContext) - 类 中的方法io.github.changebooks.kafka.KafkaBatchListener

计算分页，多线程消费

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

page(List<T>, int) - 类 中的静态方法io.github.changebooks.kafka.PageUtils

计算分页

page(List<T>, int) - 类 中的静态方法io.github.changebooks.kafka.PageUtils

计算分页

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

分页

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

分页

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

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

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

设置一个记录

setAttribute(String, Object) - 接口 中的方法io.github.changebooks.kafka.KafkaBatchContext

新增一个属性

setAttribute(String, Object) - 接口 中的方法io.github.changebooks.kafka.KafkaBatchContext

新增一个属性

setAttribute(String, Object) - 类 中的方法io.github.changebooks.kafka.KafkaBatchContextImpl

setAttribute(String, Object) - 类 中的方法io.github.changebooks.kafka.KafkaBatchContextImpl

setCode(int) - 类 中的方法io.github.changebooks.kafka.KafkaContext

setCode(int) - 类 中的方法io.github.changebooks.kafka.KafkaContext

setMessage(String) - 类 中的方法io.github.changebooks.kafka.KafkaContext

setMessage(String) - 类 中的方法io.github.changebooks.kafka.KafkaContext

setRecord(ConsumerRecord<String, String>) - 类 中的方法io.github.changebooks.kafka.KafkaContext

setRecord(ConsumerRecord<String, String>) - 类 中的方法io.github.changebooks.kafka.KafkaContext

setThreadNum(int) - 类 中的方法io.github.changebooks.kafka.KafkaBatchListener

设置线程数 实际线程数 = CEIL(总行数 / CEIL(总行数 / 线程数))

setThreadNum(int) - 类 中的方法io.github.changebooks.kafka.KafkaBatchListener

设置线程数 实际线程数 = CEIL(总行数 / CEIL(总行数 / 线程数))

SUCCESS_OK - 类 中的静态变量io.github.changebooks.kafka.KafkaContext

OK

SUCCESS_OK - 类 中的静态变量io.github.changebooks.kafka.KafkaContext

OK

A C G I K L O P S