diff --git a/src/main/kotlin/consumer/GlueConsumer.kt b/src/main/kotlin/consumer/GlueConsumer.kt
index f87defd..93f6ae3 100644
--- a/src/main/kotlin/consumer/GlueConsumer.kt
+++ b/src/main/kotlin/consumer/GlueConsumer.kt
@@ -33,7 +33,7 @@ class GlueConsumer() : Consumer {
     }
 
     override fun handleDelivery(consumerTag : String?, envelope : Envelope?, basicProperties : AMQP.BasicProperties?, body : ByteArray?) {
-        val rawJson = body!!.toString()
+        val rawJson = body!!.toString(Charsets.UTF_8)
         println(rawJson)
         val probability = Random.nextDouble(0.0,1.0)
         val outputObject = OutputModel(tag=rawJson, probability=probability)