diff --git a/src/consumer/consumerGroup.js b/src/consumer/consumerGroup.js index 29c93fa3d..1eea5c415 100644 --- a/src/consumer/consumerGroup.js +++ b/src/consumer/consumerGroup.js @@ -95,7 +95,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