more explicit typing for compiler to figure out

AbsaOSS · Oct 23, 2024 · 0be560a · 0be560a
1 parent 3e5d908
commit 0be560a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/examples/src/main/scala/za/co/absa/kafkacase/examples/reader/ReaderReadOnce.scala b/examples/src/main/scala/za/co/absa/kafkacase/examples/reader/ReaderReadOnce.scala
@@ -22,5 +22,5 @@ import za.co.absa.kafkacase.reader.Reader
 
 object ReaderReadOnce {
   def apply[T: Decoder](readerConf: Config, topicName: String): Unit =
-    Reader.readOnce[T](readerConf, topicName, println)
+    Reader.readOnce[T](readerConf, topicName, (item: (String, Either[String, T])) => println(item))
 }