fix: continue in for loop when releasing an inexistent partition lock

XiaoMi · Mar 15, 2023 · 66a047e · 66a047e
1 parent 80abc17
commit 66a047e
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/consumer/TalosConsumer.go b/consumer/TalosConsumer.go
@@ -503,7 +503,7 @@ func (c *TalosConsumer) releasePartitionLock(toReleaseList []int32) {
 	for _, partitionId := range toReleaseList {
 		if _, ok := c.partitionFetcherMap[partitionId]; !ok {
 			c.log.Errorf("partitionFetcher map not contains partition: %d", partitionId)
-			return
+			continue
 		}
 		c.partitionFetcherMap[partitionId].Unlock()
 	}

diff --git a/consumer/TalosTopicsConsumer.go b/consumer/TalosTopicsConsumer.go
@@ -518,7 +518,7 @@ func (c *TalosTopicsConsumer) releasePartitionLock(toReleaseList TopicPartitions
 	for _, partitionId := range toReleaseList {
 		if _, ok := c.partitionFetcherMap[partitionId]; !ok {
 			c.log.Errorf("partitionFetcher map not contains partition: %d", partitionId)
-			return
+			continue
 		}
 		c.partitionFetcherMap[partitionId].Unlock()
 	}