From 4ff43dddeaa52900a49a4aac8fec7ab93b9554e2 Mon Sep 17 00:00:00 2001 From: Tom Lee Date: Tue, 4 Dec 2018 03:49:35 -0800 Subject: [PATCH] RefreshCoordinator() will handle closing the coordinator if necessary --- consumer_group.go | 4 ---- 1 file changed, 4 deletions(-) diff --git a/consumer_group.go b/consumer_group.go index d577c57c1..03c1c3912 100644 --- a/consumer_group.go +++ b/consumer_group.go @@ -221,8 +221,6 @@ func (c *consumerGroup) newSession(ctx context.Context, topics []string, handler return nil, join.Err } - _ = coordinator.Close() - return c.retryNewSession(ctx, topics, handler, retries, true) case ErrRebalanceInProgress: // retry after backoff if retries <= 0 { @@ -264,8 +262,6 @@ func (c *consumerGroup) newSession(ctx context.Context, topics []string, handler return nil, sync.Err } - _ = coordinator.Close() - return c.retryNewSession(ctx, topics, handler, retries, true) case ErrRebalanceInProgress: // retry after backoff if retries <= 0 {