diff --git a/log-explorer-plugins/cloudwatch/src/main/java/com/tinubu/logexplorer/cloudwatch/CloudWatchBackend.java b/log-explorer-plugins/cloudwatch/src/main/java/com/tinubu/logexplorer/cloudwatch/CloudWatchBackend.java index 7a0879d69f21b06d9973514b0fd854e09549d9a2..591f17b8bdde7bbdc9c0b9ca5c8850b7b2533924 100644 --- a/log-explorer-plugins/cloudwatch/src/main/java/com/tinubu/logexplorer/cloudwatch/CloudWatchBackend.java +++ b/log-explorer-plugins/cloudwatch/src/main/java/com/tinubu/logexplorer/cloudwatch/CloudWatchBackend.java @@ -39,8 +39,6 @@ import java.util.List; import java.util.function.BiConsumer; import java.util.regex.Pattern; -import org.apache.logging.log4j.Level; -import org.apache.logging.log4j.core.config.Configurator; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -148,9 +146,6 @@ public class CloudWatchBackend implements Backend { logger.debug("Initialize CloudWatch client with '{}'", configuration); - Configurator.setLevel("com.amazonaws", Boolean.TRUE.equals(debug) ? Level.DEBUG : Level.INFO); - Configurator.setLevel("com.amazonaws.auth.profile.internal.BasicProfileConfigLoader", Level.ERROR); - String region = configuration.backendUris().get(0).getHost(); SdkHttpClient clientConfiguration = ApacheHttpClient @@ -338,7 +333,8 @@ public class CloudWatchBackend implements Backend { Retry retry = registry.retry(call); if (logger.isDebugEnabled()) { - retry.getEventPublisher() + retry + .getEventPublisher() .onRetry(event -> logger.debug("Retry call to '{}' # {}", event.getName(), event.getNumberOfRetryAttempts())); @@ -559,6 +555,7 @@ public class CloudWatchBackend implements Backend { DescribeLogStreamsRequest .builder() .logGroupName(group) + .logStreamNamePrefix(streamPrefix) .nextToken(finalNextToken) .build())); streams.addAll(describeLogGroupsResult