fix: producer RetryQueue memory leak (#287)

aliyun · Aug 12, 2024 · 0bbc541 · 0bbc541
1 parent 9a152f5
commit 0bbc541
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/producer/retry_queue.go b/producer/retry_queue.go
@@ -70,6 +70,7 @@ func (retryQueue *RetryQueue) Pop() interface{} {
 	old := retryQueue.batch
 	n := len(old)
 	item := old[n-1]
+	old[n-1] = nil
 	retryQueue.batch = old[0 : n-1]
 	return item
 }