kafka-observe - npm Package Compare versions

Comparing version 1.0.10 to 1.0.11

IO/consumer.js

@@ -39,3 +39,9 @@ const kafka = require("kafka-node");
 
+		consumer.on("connect", () => {
+			logging.report("kafka consumer connected");
+		});
+
 		consumer.on("message", (message) => {
+			console.log(message);
+
 			if (message && message.value && message.topic) {
@@ -42,0 +48,0 @@ let payload;

IO/consumerGroup.js

@@ -40,3 +40,8 @@ const kafka = require("kafka-node");
 
+		consumer.on("connect", () => {
+			logging.report("kafka consumer group connected");
+		})
+
 		consumer.on("message", (message) => {
+			console.log(message);
 
@@ -43,0 +48,0 @@ if (message && message.value && message.topic) {

package.json

 {
   "name": "kafka-observe",
-  "version": "1.0.10",
+  "version": "1.0.11",
   "description": "",
@@ -5,0 +5,0 @@ "main": "index.js",

No alert changes

Improved metrics

Total package byte prevSize

11555

increased by2.03%

Lines of code

350

increased by2.34%

No dependency changes