From 9a462b7bad572491b78ae75bc11302ec62032d58 Mon Sep 17 00:00:00 2001
From: Pablo Sanfilippo <pablo@slingshotaerospace.com>
Date: Wed, 5 Aug 2020 11:25:04 -0300
Subject: [PATCH] stream.consumer.on -> stream.on

---
 src/kafka-pubsub.ts | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/kafka-pubsub.ts b/src/kafka-pubsub.ts
index 60015f8..cad223d 100644
--- a/src/kafka-pubsub.ts
+++ b/src/kafka-pubsub.ts
@@ -113,7 +113,7 @@ export class KafkaPubSub implements PubSubEngine {
         {},
         { topics: [topic] }
     );
-    stream.consumer.on('data', (message) => {
+    stream.on('data', (message) => {
       let parsedMessage = JSON.parse(message.value.toString())
 
       // Using channel abstraction