| 接口 | 说明 |
|---|---|
| KafkaBatchConsumer |
批量消费
|
| KafkaBatchContext |
批量消费上下文
|
| 类 | 说明 |
|---|---|
| KafkaBatchContextImpl |
批量消费上下文的默认实现
|
| KafkaBatchListener |
消息分页，并行消费
总行数 / 线程数 = 每线程处理行数
可以整除时，线程数 == 实际线程数，如：总行数 = 9 和 线程数 = 3，实际结果：实际线程数 = 3，每线程处理行数 = 3
不能整除时，线程数 !
|
| KafkaContext |
消费上下文
|
| KafkaHeaders |
标头
|
| KafkaLogId |
日志id
|
| KafkaTraceId |
追溯id
|
| LogConsumerInterceptor<K,V> |
拦截接收消息
从已接收消息获取日志信息，设置日志上下文
|
| LogProducerInterceptor<K,V> |
拦截发送消息
从日志上下文获取日志信息，设置待发送消息
|
| PageUtils |
分页
|
Copyright © 2023. All rights reserved.