kafka-observe - npm Package Compare versions

Comparing version 2.0.2-beta-2 to 2.0.2-beta3

IO/consumer.js

@@ -31,4 +31,4 @@ const { Kafka, logLevel } = require("kafkajs");
 
-	sendUpdateToObservers({ topic, payload }) {
-		this[`${topic}Subject`].next(payload);
+	sendUpdateToObservers({ topic, payload, headers }) {
+		this[`${topic}Subject`].next({...payload, headers});
 	}
@@ -35,0 +35,0 @@

IO/consumerGroup.js

@@ -31,4 +31,4 @@ const { Kafka, logLevel } = require("kafkajs");
 
-	sendUpdateToObservers({ topic, payload }) {
-		this[`${topic}Subject`].next(payload);
+	sendUpdateToObservers({ topic, payload, headers }) {
+		this[`${topic}Subject`].next({...payload, headers});
 	}
@@ -35,0 +35,0 @@

package.json

 {
   "name": "kafka-observe",
-  "version": "2.0.2-beta-2",
+  "version": "2.0.2-beta3",
   "description": "",
@@ -5,0 +5,0 @@ "main": "index.js",

No alert changes

Improved metrics

Total package byte prevSize

18733

increased by0.24%

No dependency changes