Remove NOISY log from Mongo StreamAcknowledgementManager (opensearch-…

…project#5321) Remove NOISY log from Mongo StreamAcknowledgementManager. We have metric to capture when this condition occurs, so removing logs as they are noisy Signed-off-by: Dinu John <[email protected]>
jcrean · Jan 10, 2025 · 3f7f5d2 · 3f7f5d2
1 parent 2aa376e
commit 3f7f5d2
Showing 1 changed file with 0 additions and 4 deletions.
diff --git a/...in/java/org/opensearch/dataprepper/plugins/mongo/stream/StreamAcknowledgementManager.java b/...in/java/org/opensearch/dataprepper/plugins/mongo/stream/StreamAcknowledgementManager.java
@@ -18,9 +18,6 @@
 import java.util.concurrent.Executors;
 import java.util.function.Consumer;
 
-import static org.opensearch.dataprepper.logging.DataPrepperMarkers.NOISY;
-
-
 public class StreamAcknowledgementManager {
     private static final Logger LOG = LoggerFactory.getLogger(StreamAcknowledgementManager.class);
     private static final int CHECKPOINT_RECORD_INTERVAL = 50;
@@ -111,7 +108,6 @@ private void monitorAcknowledgment(final ExecutorService executorService, final
                     }
                 } else {
                     if (System.currentTimeMillis() - lastCheckpointTime >= checkPointIntervalInMs) {
-                        LOG.info(NOISY, "No records processed. Extend the lease of the partition worker.");
                         partitionCheckpoint.extendLease();
                         this.noDataExtendLeaseCount.increment();
                         lastCheckpointTime = System.currentTimeMillis();