From 6b2d508b8904d721e5b28152e3f53880cc6ba3c2 Mon Sep 17 00:00:00 2001 From: Lev Zakharov Date: Fri, 29 Dec 2023 11:51:13 +0300 Subject: [PATCH] fix: don't waste time for backoff on member id required error --- consumer_group.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/consumer_group.go b/consumer_group.go index 91b6e584e2..05030efbca 100644 --- a/consumer_group.go +++ b/consumer_group.go @@ -326,7 +326,7 @@ func (c *consumerGroup) newSession(ctx context.Context, topics []string, handler // response and send another join request with that id to actually join the // group c.memberID = join.MemberId - return c.retryNewSession(ctx, topics, handler, retries+1 /*keep retry time*/, false) + return c.newSession(ctx, topics, handler, retries) case ErrFencedInstancedId: if c.groupInstanceId != nil { Logger.Printf("JoinGroup failed: group instance id %s has been fenced\n", *c.groupInstanceId)