diff --git a/common/src/main/scala/com/github/baklanovsoft/imagehosting/kafka/KafkaJsonDeserializer.scala b/common/src/main/scala/com/github/baklanovsoft/imagehosting/kafka/KafkaJsonDeserializer.scala
index edd4fd1..a931fdb 100644
--- a/common/src/main/scala/com/github/baklanovsoft/imagehosting/kafka/KafkaJsonDeserializer.scala
+++ b/common/src/main/scala/com/github/baklanovsoft/imagehosting/kafka/KafkaJsonDeserializer.scala
@@ -19,7 +19,7 @@ trait KafkaJsonDeserializer {
       decodeByteArray[T](bytes) match {
         case Left(value)  =>
           KafkaJsonDecodingError(
-            s"Can't decode json kafka message: ${value.getMessage}. Original message: $bytes"
+            s"Can't decode json kafka message: ${value.getMessage}. Original message: ${new String(bytes)}"
           )
             .raiseError[F, T]
         case Right(value) => value.pure[F]