fixed panic on calling updateMetadata on closed client

IBM · Nov 1, 2019 · a5a3dd2 · a5a3dd2
1 parent 675b0b1
commit a5a3dd2
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/client.go b/client.go
@@ -833,6 +833,10 @@ func (client *client) tryRefreshMetadata(topics []string, attemptsRemaining int,
 
 // if no fatal error, returns a list of topics that need retrying due to ErrLeaderNotAvailable
 func (client *client) updateMetadata(data *MetadataResponse, allKnownMetaData bool) (retry bool, err error) {
+	if client.Closed() {
+		return
+	}
+
 	client.lock.Lock()
 	defer client.lock.Unlock()