Fix OnMessage Output

opiepj · opiepj · commit 1276393153a9 · 2018-08-27T13:27:07.000-07:00
diff --git a/src/consumer.js b/src/consumer.js
@@ -97,7 +97,8 @@ class Consumer extends KafkaClient {
       // @TODO remove this after test
       console.log(JSON.stringify(message));
       console.log(message.value.toString());
-      this._messageDispatcher.next(message.value.toString());
+      message.value = message.value.toString();
+      this._messageDispatcher.next(message);
 
     });
   }

Original file line number	Diff line number	Diff line change
`@@ -97,7 +97,8 @@ class Consumer extends KafkaClient {`
`97`	`97`	`// @TODO remove this after test`
`98`	`98`	`console.log(JSON.stringify(message));`
`99`	`99`	`console.log(message.value.toString());`
`100`		`- this._messageDispatcher.next(message.value.toString());`
	`100`	`+ message.value = message.value.toString();`
	`101`	`+ this._messageDispatcher.next(message);`
`101`	`102`
`102`	`103`	`});`
`103`	`104`	`}`