From 1ff82cfb8d851051ecd1cd370738d92439ce95d2 Mon Sep 17 00:00:00 2001
From: Kerkesni <walid.elansari@scality.com>
Date: Thu, 28 Sep 2023 11:36:42 +0200
Subject: [PATCH] change default kafka consumer params

---
 lib/BackbeatConsumer.js | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/lib/BackbeatConsumer.js b/lib/BackbeatConsumer.js
index 159666f560..29ea42a037 100644
--- 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) {