From 6acb2767144a840d9cc423f2917617e3372da7be Mon Sep 17 00:00:00 2001 From: Lumo Date: Sat, 21 Jan 2023 04:32:52 +0800 Subject: [PATCH] fix: use newConsumer method in newConsumerGroup method (#2424) --- consumer_group.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 }