Try catch message

Author: opiepj

src/consumer.js

@@ -97,7 +97,12 @@ class Consumer extends KafkaClient {
       // @TODO remove this after test
       console.log(JSON.stringify(message));
       console.log(message.value.toString());
-      message.value = message.value.toString();
+      try {
+        message.value = JSON.parse(message.value.toString());
+      } catch (err) {
+        // Ignore error
+        console.error('Failed to parse message', err);
+      }
       this._messageDispatcher.next(message);
 
     });

src/index.d.ts

@@ -155,8 +155,8 @@ export interface TopicConfig {
   'consume.callback.max.messages'?: number;
 }
 
-export interface MessagePayload {
-  value: Buffer; // message contents as a Buffer
+export interface MessagePayload<Type> {
+  value: Type; // message contents
   size: number; // size of the message, in bytes
   topic: string; // topic the message comes from
   offset: number; // offset the message was read from