From c21bf635391c9988ea9baf664f712289856ec0b1 Mon Sep 17 00:00:00 2001
From: keyboardbobo <cjb20032003@126.com>
Date: Wed, 1 Mar 2023 17:28:21 +0800
Subject: [PATCH] Update ReplicaManager.java

If all tasks are sent, cancel the timer tasks to avoid full gc or oom
---
 .../pulsar/handlers/kop/storage/ReplicaManager.java             | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/storage/ReplicaManager.java b/kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/storage/ReplicaManager.java
index 17105d4e57..380fdb7850 100644
--- a/kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/storage/ReplicaManager.java
+++ b/kafka-impl/src/main/java/io/streamnative/pulsar/handlers/kop/storage/ReplicaManager.java
@@ -143,6 +143,8 @@ public CompletableFuture<Map<TopicPartition, ProduceResponse.PartitionResponse>>
                 return;
             }
             if (restTopicPartitionNum == 0) {
+                // If all tasks are sent, cancel the timer tasks to avoid full gc or oom
+                producePurgatory.checkAndComplete(new DelayedOperationKey.TopicPartitionOperationKey(topicPartition));
                 complete.run();
             }
         };