From c6ef2c8f5993d5a63432eebf050f8443ca073d7e Mon Sep 17 00:00:00 2001 From: antonbabak Date: Wed, 18 Dec 2024 09:35:08 +0100 Subject: [PATCH] Add Sampling for Logs --- .../java/org/prebid/cache/handlers/cache/CacheHandler.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/src/main/java/org/prebid/cache/handlers/cache/CacheHandler.java b/src/main/java/org/prebid/cache/handlers/cache/CacheHandler.java index 6d0bbca..496c897 100644 --- a/src/main/java/org/prebid/cache/handlers/cache/CacheHandler.java +++ b/src/main/java/org/prebid/cache/handlers/cache/CacheHandler.java @@ -77,7 +77,7 @@ private Mono handleErrorMetrics(final Throwable error, final Ser + ". Request URI: " + request.uri(), samplingRate); } else if (error instanceof BadRequestException) { - log.error(error.getMessage()); + conditionalLogger.error(error.getMessage(), samplingRate); } else if (error instanceof TimeoutException) { metricsRecorder.markMeterForTag(this.metricTagPrefix, MetricsRecorder.MeasurementTag.ERROR_TIMEDOUT); } else if (error instanceof DataBufferLimitException) { @@ -86,8 +86,9 @@ private Mono handleErrorMetrics(final Throwable error, final Ser "Request length: `" + contentLength + "` exceeds maximum size limit", samplingRate); } else { - log.error("Error occurred while processing the request: '{}', cause: '{}'", - ExceptionUtils.getMessage(error), ExceptionUtils.getMessage(error)); + conditionalLogger.error("Error occurred while processing the request: '%s', cause: '%s'".formatted( + ExceptionUtils.getMessage(error), ExceptionUtils.getMessage(error)), + samplingRate); } return builder.error(Mono.just(error), request)