Quarkus Kafka生产者批量配置异常：批量被限制为500条

你的问题核心是Kafka生产者客户端的默认队列缓冲消息数限制导致的。Apache Kafka客户端（SmallRye Kafka基于它）默认配置了queue.buffering.max.messages=500，这个参数控制生产者内部缓冲队列能容纳的最大消息数量。当缓冲队列里的消息数达到500时，不管linger.ms设置的等待时间是否到期，生产者都会立即发送该批次，这就是你频繁收到500条一批消息的原因。

需要补充的配置项 #

在生产者配置中添加以下参数，调整缓冲队列的最大消息数：

mp.messaging.outgoing.data-values.queue.buffering.max.messages=1500

这个值可以按需设置（比如你期望容纳30秒内生成的1500条消息，就设为1500或更大）。配置后，生产者会优先等待缓冲队列填满到指定数量，或等待linger.ms超时，满足任一条件就发送对应批次。

额外注意点 #

• 如果后续消息体积变大，先达到batch.size=1000000（1MB）的阈值时，生产者也会提前发送批次，这是正常的触发逻辑。
• 确保生产者有足够内存缓冲这些消息，避免出现内存溢出问题。
• 消费者端的批量消费依赖生产者发送的批次，解决生产者配置问题后，消费者就能收到符合预期的大批次消息。

内容的提问来源于stack exchange，提问作者jesantana