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