Skip to content

Commit 0bbc541

Browse files
authored
fix: producer RetryQueue memory leak (aliyun#287)
1 parent 9a152f5 commit 0bbc541

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

producer/retry_queue.go

+1
Original file line numberDiff line numberDiff line change
@@ -70,6 +70,7 @@ func (retryQueue *RetryQueue) Pop() interface{} {
7070
old := retryQueue.batch
7171
n := len(old)
7272
item := old[n-1]
73+
old[n-1] = nil
7374
retryQueue.batch = old[0 : n-1]
7475
return item
7576
}

0 commit comments

Comments
 (0)