fix(kafka-runner): wrong logger for KafkaStreamService

kestra-io · May 4, 2022 · c36610f · c36610f
1 parent ed86d0d
commit c36610f
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/runner-kafka/src/main/java/io/kestra/runner/kafka/services/KafkaStreamService.java b/runner-kafka/src/main/java/io/kestra/runner/kafka/services/KafkaStreamService.java
@@ -154,7 +154,7 @@ private Stream(Topology topology, Properties props, MetricRegistry meterRegistry
 
         public synchronized void start(final KafkaStreams.StateListener listener) throws IllegalStateException, StreamsException {
             this.setUncaughtExceptionHandler(e -> {
-                log.error("Uncaught exception in Kafka Stream, closing !", e);
+                this.logger.error("Uncaught exception in Kafka Stream, closing !", e);
                 return StreamsUncaughtExceptionHandler.StreamThreadExceptionResponse.SHUTDOWN_APPLICATION;
             });
 
@@ -182,12 +182,12 @@ public synchronized void start(final KafkaStreams.StateListener listener) throws
                     newState == State.NOT_RUNNING ||
                     newState == State.PENDING_SHUTDOWN
                 ) {
-                    log.warn("Switching stream state from {} to {}", oldState, newState);
+                    this.logger.warn("Switching stream state from {} to {}", oldState, newState);
                 } else if (
                     newState == State.PENDING_ERROR ||
                     newState == State.ERROR
                 ) {
-                    log.error("Switching stream state from {} to {}", oldState, newState);
+                    this.logger.error("Switching stream state from {} to {}", oldState, newState);
                 } else {
                     logger.info("Switching stream state from {} to {}", oldState, newState);
                 }