| 拉取 | fetch.min.bytes(默认 1)、fetch.max.wait.ms(默认 500) |
|---|---|
| 处理 | max.poll.records(默认 500)、max.poll.interval.ms(默认 300000,3.0 起会话超时默认 45000) |
| 内存 | max.partition.fetch.bytes(默认 1MB) |
批量消费配置
批量消费配置
fetch.min.bytes=1048576
fetch.max.wait.ms=500
max.poll.records=1000
max.poll.interval.ms=600000调大 max.poll.records 提升吞吐,但要同步评估单批处理时间与 max.poll.interval.ms 的关系。