max.poll.records 控制每次 poll() 返回的最大记录数，影响吞吐、延迟与内存；值小则调用频繁但响应快，值大易因处理超时触发 rebalance；需协同调整 max.poll.interval.ms 等参数，并依业务场景合理设置。
max.poll.records 是 Kafka 消费者端一个关键参数，它控制每次调用 poll() 方法时最多返回多少条消息（即记录数），**不是并发数，也不是线程数**。这个值直接影响单次拉取的消息批次大小，进而影响消费吞吐、处理延迟和内存占用。
作用与影响
该参数限制的是 poll() 返回的 ConsumerRecords 中包含的记录总数。比如设为 500，那么无论分区有多少、消息多大，一次 poll() 最多只给你 500 条记录。
- 值太小：频繁调用
poll()，增加网络和 CPU 开销，可能降低吞吐；但单次处理压力小，响应快、rebalance 更灵敏 - 值太大：单次拉取多，吞吐可能提升，但若业务处理慢，容易超时触发
rebalance（因未及时提交 offset 或心跳超时） - 注意：它不改变消费者线程数或分区分配逻辑，也不直接控制“并发消费”——Kafka 消费者本身是单线程模型（每个 consumer 实例），真正的并发靠多实例或多线程手动处理 records
如何配置
在创建 KafkaConsumer 时，通过 props 设置：
Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("group.id", "my-group");
props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
// ?核心配置
props.put("max.poll.records", "100"); // 类型是 String，实际转为 int
也可以用常量形式（推荐，避免拼写错误）：
Docker Image Puller
下载
使用 Python 脚本下载 Docker 镜像并打包为 tar 文件。用户说“下载镜像”“拉取镜像”“pull xxx”“帮我下载 nginx 镜像”等时触发。支持 SOCKS5 代理直连（推荐）和国内镜像站加速两种模式。
立即学习“Java免费学习笔记（深入）”；
props.put(ConsumerConfig.MAX_POLL_RECORDS_CONFIG, "100");
搭配使用的注意事项
单独调大 max.poll.records 很危险，必须同步检查以下参数：
-
max.poll.interval.ms：两次
poll()的最大允许间隔，默认 5 分钟。如果处理 1000 条消息耗时超过该值，消费者会被踢出 group，触发 rebalance -
session.timeout.ms 和 heartbeat.interval.ms：心跳机制相关，确保消费者活跃。当
max.poll.records增大后，建议适当调大max.poll.interval.ms，并保证heartbeat.interval.ms < session.timeout.ms / 3 -
处理逻辑要可控：避免在
poll()后的循环里做阻塞操作（如远程 HTTP 调用、大事务等）。可考虑异步化或批量提交 + 限流
典型适用场景参考
没有绝对最优值，需结合业务节奏调整：
- 实时性要求高（如风控）、单条处理快 → 设为 10~50
- 离线 ETL、日志聚合、批量写库 → 可设为 500~5000，同时调大
max.poll.interval.ms（如 10~30 分钟） - 消息体很大（如含图片 Base64）→ 即使数量少，也要注意堆内存，建议优先压缩或减小单条 size，再调
max.poll.records
