From 299e8de92134f0196d9c790e61d6f5add9d96283 Mon Sep 17 00:00:00 2001
From: XuJiacheng <xujiacheng@blw.com>
Date: Fri, 30 Jan 2026 20:13:05 +0800
Subject: [PATCH] =?UTF-8?q?feat(kafka):=20=E6=B7=BB=E5=8A=A0=E6=B6=88?=
 =?UTF-8?q?=E8=B4=B9=E8=80=85=E9=85=8D=E7=BD=AE=E5=8F=82=E6=95=B0=E4=BB=A5?=
 =?UTF-8?q?=E4=BC=98=E5=8C=96=E6=B6=88=E6=81=AF=E6=8B=89=E5=8F=96=E8=A1=8C?=
 =?UTF-8?q?=E4=B8=BA?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

新增 fetchMaxBytes、fetchMinBytes 和 fetchMaxWaitMs 配置项，允许更精细地控制消费者从 Kafka 拉取消息的行为，从而优化网络利用率和消费延迟。
---
 src/kafka/consumer.js | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/src/kafka/consumer.js b/src/kafka/consumer.js
index 211a3b4..f6bc571 100644
--- a/src/kafka/consumer.js
+++ b/src/kafka/consumer.js
@@ -55,6 +55,9 @@ class KafkaConsumer {
       fromOffset: this.config.fromOffset ?? 'latest',
       encoding: 'buffer',
       keyEncoding: 'buffer',
+      fetchMaxBytes: this.config.fetchMaxBytes,
+      fetchMinBytes: this.config.fetchMinBytes,
+      fetchMaxWaitMs: this.config.fetchMaxWaitMs,
     };
 
     if (this.config?.sslEnabled === true) {