From 62c278ae6d050557c0569f62e07b083222b441d4 Mon Sep 17 00:00:00 2001
From: Halvard Morstad <halvardm@amazon.de>
Date: Thu, 31 Oct 2024 16:39:24 +0100
Subject: [PATCH] fix: fixed typo (mongo -> neptune)

Signed-off-by: Amanda Xiang <xianjial@amazon.de>
---
 .../source/neptune/stream/StreamAcknowledgementManager.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/stream/StreamAcknowledgementManager.java b/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/stream/StreamAcknowledgementManager.java
index d5eb906642..c0e90d9af2 100644
--- a/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/stream/StreamAcknowledgementManager.java
+++ b/data-prepper-plugins/neptune-source/src/main/java/org/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) {