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
index 16612e7..e98064e 100644
--- 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))
 }