fix: don't waste time for backoff on member id required error

IBM · Dec 29, 2023 · 6b2d508 · 6b2d508
1 parent 4d31d23
commit 6b2d508
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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)