diff --git a/lib/BackbeatConsumer.js b/lib/BackbeatConsumer.js
index 89a2d7440..98764b69f 100644
--- a/lib/BackbeatConsumer.js
+++ b/lib/BackbeatConsumer.js
@@ -179,6 +179,7 @@ class BackbeatConsumer extends EventEmitter {
             'offset_commit_cb': this._onOffsetCommit.bind(this),
             // automatically create topic
             'allow.auto.create.topics': true,
+            'topic.metadata.refresh.interval.ms': 10000,
         };
         const topicParams = {};
         if (this._fromOffset !== undefined) {