From 09f29cf466f97a1c663cc3b401d6b9f29edb421d 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 Signed-off-by: Lev Zakharov --- consumer_group.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/consumer_group.go b/consumer_group.go index 91b6e584e..05030efbc 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)