diff --git a/consumer_group.go b/consumer_group.go index 33a231477..1d1ce0fe2 100644 --- a/consumer_group.go +++ b/consumer_group.go @@ -83,7 +83,7 @@ func NewConsumerGroup(addrs []string, groupID string, config *Config) (ConsumerG return c, nil } -// NewConsumerFromClient creates a new consumer group using the given client. It is still +// NewConsumerGroupFromClient creates a new consumer group using the given client. It is still // necessary to call Close() on the underlying client when shutting down this consumer. // PLEASE NOTE: consumer groups can only re-use but not share clients. func NewConsumerGroupFromClient(groupID string, client Client) (ConsumerGroup, error) {