Use correct request proto version

bsm · Mar 7, 2018 · 66a68d7 · 66a68d7
1 parent cf455bc
commit 66a68d7
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/consumer.go b/consumer.go
@@ -708,8 +708,7 @@ func (c *Consumer) syncGroup(strategy *balancer) (map[string][]int32, error) {
 
 	for memberID, topics := range strategy.Perform(c.client.config.Group.PartitionStrategy) {
 		if err := req.AddGroupAssignmentMember(memberID, &sarama.ConsumerGroupMemberAssignment{
-			Version: 1,
-			Topics:  topics,
+			Topics: topics,
 		}); err != nil {
 			return nil, err
 		}