| 类和说明 |
|---|
| KafkaBatchConsumer
批量消费
|
| KafkaBatchContext
批量消费上下文
|
| KafkaBatchListener
消息分页,并行消费
总行数 / 线程数 = 每线程处理行数
可以整除时,线程数 == 实际线程数,如:总行数 = 9 和 线程数 = 3,实际结果:实际线程数 = 3,每线程处理行数 = 3
不能整除时,线程数 !
|
| KafkaContext
消费上下文
|
Copyright © 2023. All rights reserved.