diff --git a/lib/kafka-consumer.js b/lib/kafka-consumer.js
index <HASH>..<HASH> 100644
--- a/lib/kafka-consumer.js
+++ b/lib/kafka-consumer.js
@@ -102,7 +102,8 @@ Consumer.prototype._onWrapper = function (consumerInstance, eventName, cb) {
     if (!this.valueSchemas[message.topic]) {
       console.log('KafkaAvro :: Warning, consumer did not find topic on SR:',
         message.topic);
-      message.parsed = JSON.parse(message.toString('utf-8'));
+
+      message.parsed = JSON.parse(message.value.toString('utf-8'));
 
       cb(message);
       return;
@@ -141,7 +142,7 @@ Consumer.prototype._transformAvro = function (topicName, data, encoding, callbac
   if (!this.valueSchemas[topicName]) {
     console.log('KafkaAvro :: Warning, consumer did not find topic on SR:',
       topicName);
-    data.parsed = JSON.parse(data.toString('utf-8'));
+    data.parsed = JSON.parse(data.value.toString('utf-8'));
 
     callback(null, data);
     return;
fix deserializing when topic not found in SR