第13篇:性能调优 —— 找到瓶颈,精准优化系列:Kafka × Spring Boot:参数精讲与生产落地实战本篇关键词:吞吐量 · 瓶颈定位 ·concurrency· 批量消费 · Partition 设计 · 线程池隔离📌 本篇导读Kafka 性能调优最忌讳的事情是:没有找到瓶颈就开始乱改参数。本篇的调优思路:先搞清楚吞吐量的计算公式,理解上限在哪里定位瓶颈(是 Producer 慢、Broker 慢还是 Consumer 慢?)针对瓶颈精准调优给出不同场景的完整参数配置一、消费吞吐量的本质公式最大消费吞吐量(条/秒) = min(Partition 数, concurrency) × 单线程处理速度(条/秒) 单线程处理速度 = 1000ms ÷ 单条平均处理时间(ms) 示例: 单条处理耗时 20ms → 50条/秒/线程 Topic 有 6 个 Partition,concurrency=6 最大吞吐 = 6 × 50 = 300条/秒 想要更高吞吐,只有两条路: 路径A:增加 Partition 数 + 增加 concurrency(横向扩展) 路径B