Skip to content

Commit

Permalink
Remove NOISY log from Mongo StreamAcknowledgementManager
Browse files Browse the repository at this point in the history
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]>
  • Loading branch information
dinujoh authored Jan 9, 2025
1 parent 2aa376e commit 38661b3
Showing 1 changed file with 0 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down Expand Up @@ -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();
Expand Down

0 comments on commit 38661b3

Please sign in to comment.