@ovotech/avro-kafkajs
Advanced tools
Comparing version 0.8.0 to 0.8.1
@@ -51,3 +51,3 @@ "use strict"; | ||
: payload.message.key; | ||
if (payload.message.value !== null) { | ||
if (payload.message.value !== null && payload.message.value.length !== 0) { | ||
const { type, value } = await schemaRegistry.decodeWithType(payload.message.value, readerSchema); | ||
@@ -54,0 +54,0 @@ return eachMessage({ |
{ | ||
"name": "@ovotech/avro-kafkajs", | ||
"version": "0.8.0", | ||
"version": "0.8.1", | ||
"main": "dist/index.js", | ||
@@ -51,3 +51,3 @@ "types": "dist/index.d.ts", | ||
}, | ||
"gitHead": "9062ffaf111e96cc29d0289eb7c9b60f28767448" | ||
"gitHead": "6a5fabceeab912b718b8307bd6426f1d065218e9" | ||
} |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
51641