From 9b37f791334b468a3b11a0cb40b180696a23b635 Mon Sep 17 00:00:00 2001 From: Jorge Esteban Quilcate Otoya Date: Wed, 27 Dec 2023 09:11:46 -0500 Subject: [PATCH] chore: reduce logging --- .../kafka/tieredstorage/fetch/cache/DiskChunkCache.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/core/src/main/java/io/aiven/kafka/tieredstorage/fetch/cache/DiskChunkCache.java b/core/src/main/java/io/aiven/kafka/tieredstorage/fetch/cache/DiskChunkCache.java index d6359ad9e..005dca0d4 100644 --- a/core/src/main/java/io/aiven/kafka/tieredstorage/fetch/cache/DiskChunkCache.java +++ b/core/src/main/java/io/aiven/kafka/tieredstorage/fetch/cache/DiskChunkCache.java @@ -70,11 +70,11 @@ public Path cacheChunk(final ChunkKey chunkKey, final InputStream chunk) throws final var chunkKeyPath = chunkKey.path(); final Path tempChunkPath = config.tempCachePath().resolve(chunkKeyPath); final Path tempCached = writeToDisk(chunk, tempChunkPath); - log.debug("Chunk file has been stored to temporary caching directory {}", tempCached); + log.trace("Chunk file has been stored to temporary caching directory {}", tempCached); final Path cachedChunkPath = config.cachePath().resolve(chunkKeyPath); try { final Path newPath = Files.move(tempCached, cachedChunkPath, ATOMIC_MOVE); - log.debug("Chunk file has been moved to cache directory {}", newPath); + log.trace("Chunk file has been moved to cache directory {}", newPath); return newPath; } finally { // In case of exception during the move, the chunk file should be cleaned from temporary cache directory. @@ -101,7 +101,7 @@ public RemovalListener removalListener() { final long fileSize = Files.size(path); Files.delete(path); metrics.chunkDeleted(fileSize); - log.debug("Deleted cached file for key {} with path {} from cache directory." + log.trace("Deleted cached file for key {} with path {} from cache directory." + " The reason of the deletion is {}", key, path, cause); } else { log.warn("Path not present when trying to delete cached file for key {} from cache directory."