引言:批量的力量

单条发送 vs 批量发送:

  • 单条:1万TPS
  • 批量:10万TPS(提升10倍)

批量发送

List<Message> messages = new ArrayList<>();
for (int i = 0; i < 100; i++) {
    Message msg = new Message("topic", ("Msg" + i).getBytes());
    messages.add(msg);
}

// 批量发送(一次网络调用)
SendResult result = producer.send(messages);

批量大小限制

单批最大:4MB
建议:每批100-1000条消息

性能对比

方式TPS延迟
单条发送1万5ms
批量发送10万10ms

本文关键词批量消息 性能优化 高吞吐量