Skip to content

Commit

Permalink
Lower log level of partition processor core creation, to be virtual t…
Browse files Browse the repository at this point in the history
…hread friendly (#245)
  • Loading branch information
kawamuray authored Aug 22, 2024
1 parent ef68f65 commit 67bf421
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -72,7 +72,7 @@ public ProcessPipeline<T> newPipeline(ThreadScope scope,
TaskExtractor<T> taskExtractor = extractorFromTopic(scope);
try {
List<DecatonProcessor<T>> 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
Expand Down

0 comments on commit 67bf421

Please sign in to comment.