diff --git a/processor/src/main/java/com/linecorp/decaton/processor/runtime/internal/Processors.java b/processor/src/main/java/com/linecorp/decaton/processor/runtime/internal/Processors.java index c7d61991..982d2e8f 100644 --- a/processor/src/main/java/com/linecorp/decaton/processor/runtime/internal/Processors.java +++ b/processor/src/main/java/com/linecorp/decaton/processor/runtime/internal/Processors.java @@ -72,7 +72,7 @@ public ProcessPipeline newPipeline(ThreadScope scope, TaskExtractor taskExtractor = extractorFromTopic(scope); try { List> processors = createProcessors(scope); - logger.info("Creating partition processor core: {}", scope); + logger.debug("Creating partition processor core: {}", scope); return new ProcessPipeline<>(scope, processors, retryProcessor, taskExtractor, scheduler, metrics); } catch (Exception e) { // Catching Exception instead of RuntimeException, since