Allow topic compaction to be disabled in Pulsar Functions (apache#7677)

Co-authored-by: Jerry Peng <[email protected]>
wanghhao · Jul 28, 2020 · e2bf486 · e2bf486
1 parent fffd9f1
commit e2bf486
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...r-functions/worker/src/main/java/org/apache/pulsar/functions/worker/SchedulerManager.java b/...r-functions/worker/src/main/java/org/apache/pulsar/functions/worker/SchedulerManager.java
@@ -189,7 +189,9 @@ public synchronized void initialize() {
                     new LinkedBlockingQueue<>(5));
             executorService.setThreadFactory(new ThreadFactoryBuilder().setNameFormat("worker-scheduler-%d").build());
             scheduledExecutorService = Executors.newSingleThreadScheduledExecutor(new DefaultThreadFactory("worker-assignment-topic-compactor"));
-            scheduleCompaction(this.scheduledExecutorService, workerConfig.getTopicCompactionFrequencySec());
+            if (workerConfig.getTopicCompactionFrequencySec() > 0) {
+                scheduleCompaction(this.scheduledExecutorService, workerConfig.getTopicCompactionFrequencySec());
+            }
 
             isRunning = true;
             lastMessageProduced = null;