Skip to content

Commit

Permalink
Remove NOISY log from Mongo StreamAcknowledgementManager (#5321)
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 10, 2025
1 parent 2aa376e commit 3f7f5d2
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 3f7f5d2

Please sign in to comment.