Merge pull request #545 from Collaborne/pr/assigner-protocol-subscrib…

…ed-topics Provide the _subscribed_ topics to the protocol() function
tulios · Mar 16, 2020 · 03409e2 · 03409e2
2 parents 385be11 + 2ee7636
commit 03409e2
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/src/consumer/consumerGroup.js b/src/consumer/consumerGroup.js
@@ -98,7 +98,11 @@ module.exports = class ConsumerGroup {
       sessionTimeout,
       rebalanceTimeout,
       memberId: this.memberId || '',
-      groupProtocols: this.assigners.map(assigner => assigner.protocol({ topics: this.topics })),
+      groupProtocols: this.assigners.map(assigner =>
+        assigner.protocol({
+          topics: this.topicsSubscribed,
+        })
+      ),
     })
 
     this.generationId = groupData.generationId