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) {