Merge pull request #2329 from Jacob-bzx/main

fix: avoid panic when Metadata.RefreshFrequency is 0
IBM · Sep 15, 2022 · 07f9abf · 07f9abf
2 parents 3083a9b + 04099ad
commit 07f9abf
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/consumer_group.go b/consumer_group.go
@@ -572,6 +572,9 @@ func (c *consumerGroup) handleError(err error, topic string, partition int32) {
 }
 
 func (c *consumerGroup) loopCheckPartitionNumbers(topics []string, session *consumerGroupSession) {
+	if c.config.Metadata.RefreshFrequency == time.Duration(0) {
+		return
+	}
 	pause := time.NewTicker(c.config.Metadata.RefreshFrequency)
 	defer session.cancel()
 	defer pause.Stop()