From 3f7f5d2d76118c1495c50b0d9aae494d2f5074f3 Mon Sep 17 00:00:00 2001 From: Dinu John <86094133+dinujoh@users.noreply.github.com> Date: Thu, 9 Jan 2025 19:03:29 -0600 Subject: [PATCH] Remove NOISY log from Mongo StreamAcknowledgementManager (#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 <86094133+dinujoh@users.noreply.github.com> --- .../plugins/mongo/stream/StreamAcknowledgementManager.java | 4 ---- 1 file changed, 4 deletions(-) diff --git a/data-prepper-plugins/mongodb/src/main/java/org/opensearch/dataprepper/plugins/mongo/stream/StreamAcknowledgementManager.java b/data-prepper-plugins/mongodb/src/main/java/org/opensearch/dataprepper/plugins/mongo/stream/StreamAcknowledgementManager.java index 38d4fc9794..b8e3026fee 100644 --- a/data-prepper-plugins/mongodb/src/main/java/org/opensearch/dataprepper/plugins/mongo/stream/StreamAcknowledgementManager.java +++ b/data-prepper-plugins/mongodb/src/main/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();