| 限定符和类型 | 方法和说明 |
|---|---|
KafkaBatchListener |
KafkaBatchListener.setThreadNum(int threadNum)
设置线程数
实际线程数 = CEIL(总行数 / CEIL(总行数 / 线程数))
|
KafkaBatchListener |
KafkaBatchListener.setThreadNum(int threadNum)
设置线程数
实际线程数 = CEIL(总行数 / CEIL(总行数 / 线程数))
|
Copyright © 2023. All rights reserved.