Skip to content

Commit 6b2d508

Browse files
committed
fix: don't waste time for backoff on member id required error
1 parent 4d31d23 commit 6b2d508

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

consumer_group.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -326,7 +326,7 @@ func (c *consumerGroup) newSession(ctx context.Context, topics []string, handler
326326
// response and send another join request with that id to actually join the
327327
// group
328328
c.memberID = join.MemberId
329-
return c.retryNewSession(ctx, topics, handler, retries+1 /*keep retry time*/, false)
329+
return c.newSession(ctx, topics, handler, retries)
330330
case ErrFencedInstancedId:
331331
if c.groupInstanceId != nil {
332332
Logger.Printf("JoinGroup failed: group instance id %s has been fenced\n", *c.groupInstanceId)

0 commit comments

Comments
 (0)