Use info logs for completed/empty load

sky-uk · Feb 19, 2024 · 66541f3 · 66541f3
1 parent 2517fa4
commit 66541f3
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/main/scala/uk/sky/fs2/kafka/topicloader/TopicLoader.scala b/src/main/scala/uk/sky/fs2/kafka/topicloader/TopicLoader.scala
@@ -113,14 +113,14 @@ trait TopicLoader {
 
     Stream.eval {
       emptyOffsets.toList.traverse { (tp, o) =>
-        logger.warn(s"Not loading data from empty ${tp.show} at offset ${o.highest}")
+        logger.info(s"Not loading data from empty ${tp.show} at offset ${o.highest}")
       }
     } >>
       stream
         .scan(allHighestOffsets)(emitRecordRemovingConsumedPartition[K, V])
         .takeWhile(_.partitionOffsets.nonEmpty, takeFailure = true)
         .evalTapChunk(_.partitionLastOffset.traverse { last =>
-          logger.warn(s"Finished loading data from ${last.topicPartition.show} at offset ${last.offset}")
+          logger.info(s"Finished loading data from ${last.topicPartition.show} at offset ${last.offset}")
         })
         .collect { case WithRecord(r) => r }
   }