Merge pull request #470 from Collaborne/pr/prevent-subscription-chang…

…e-for-consumer Prevent changes in the subscriptions for running consumers
tulios · Aug 18, 2019 · e21c04d · e21c04d
2 parents 8feb245 + 4782c5a
commit e21c04d
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/src/consumer/index.js b/src/consumer/index.js
@@ -145,6 +145,10 @@ module.exports = ({
    * @return {Promise}
    */
   const subscribe = async ({ topic, fromBeginning = false }) => {
+    if (consumerGroup) {
+      throw new KafkaJSNonRetriableError('Cannot subscribe to topic while consumer is running')
+    }
+
     if (!topic) {
       throw new KafkaJSNonRetriableError(`Invalid topic ${topic}`)
     }