change default kafka consumer params

scality · Sep 28, 2023 · 1ff82cf · 1ff82cf
1 parent 1137b8f
commit 1ff82cf
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/lib/BackbeatConsumer.js b/lib/BackbeatConsumer.js
@@ -179,6 +179,9 @@ class BackbeatConsumer extends EventEmitter {
             'offset_commit_cb': this._onOffsetCommit.bind(this),
             // automatically create topic
             'allow.auto.create.topics': true,
+            'auto.commit.interval.ms': 2000,
+            'max.poll.interval.ms': 600000,
+            'session.timeout.ms': 60000,
         };
         const topicParams = {};
         if (this._fromOffset !== undefined) {