kafka-observe
Advanced tools
Comparing version 2.0.9 to 2.0.10-beta-1
@@ -27,3 +27,3 @@ const { filter } = require("rxjs/operators"); | ||
headers: { | ||
token: token.toString(), | ||
token, | ||
}, | ||
@@ -30,0 +30,0 @@ topic, |
@@ -102,2 +102,4 @@ const { Kafka, logLevel } = require("kafkajs"); | ||
console.log("unfiltered message", message); | ||
if (this.options.logAllEvents === "true") { | ||
@@ -107,3 +109,3 @@ logging.report({ | ||
payload, | ||
headers: message.headers, | ||
headers: message.headers.toString(), | ||
}); | ||
@@ -110,0 +112,0 @@ } |
{ | ||
"name": "kafka-observe", | ||
"version": "2.0.9", | ||
"version": "2.0.10-beta-1", | ||
"description": "", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
No v1
QualityPackage is not semver >=1. This means it is not stable and does not support ^ ranges.
Found 1 instance in 1 package
21904
482
2