diff --git a/consumer_group.go b/consumer_group.go
index 4f0fd6660..ecdbcfa68 100644
--- a/consumer_group.go
+++ b/consumer_group.go
@@ -126,7 +126,7 @@ func newConsumerGroup(groupID string, client Client) (ConsumerGroup, error) {
 		return nil, ConfigurationError("consumer groups require Version to be >= V0_10_2_0")
 	}
 
-	consumer, err := NewConsumerFromClient(client)
+	consumer, err := newConsumer(client)
 	if err != nil {
 		return nil, err
 	}