fix: fixed typo (mongo -> neptune)

Signed-off-by: Amanda Xiang <[email protected]>
opensearch-project · Jan 2, 2025 · 62c278a · 62c278a
1 parent 8f55824
commit 62c278a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...rg/opensearch/dataprepper/plugins/source/neptune/stream/StreamAcknowledgementManager.java b/...rg/opensearch/dataprepper/plugins/source/neptune/stream/StreamAcknowledgementManager.java
@@ -42,7 +42,7 @@ public StreamAcknowledgementManager(final AcknowledgementSetManager acknowledgem
         this.partitionAcknowledgmentTimeout = partitionAcknowledgmentTimeout;
         this.acknowledgementMonitorWaitTimeInMs = acknowledgementMonitorWaitTimeInMs;
         this.checkPointIntervalInMs = checkPointIntervalInMs;
-        executorService = Executors.newSingleThreadExecutor(BackgroundThreadFactory.defaultExecutorThreadFactory("mongodb-stream-ack-monitor"));
+        executorService = Executors.newSingleThreadExecutor(BackgroundThreadFactory.defaultExecutorThreadFactory("neptune-stream-ack-monitor"));
     }
 
     void init(final Consumer<Void> stopWorkerConsumer) {