kafka-avro - npm Package Compare versions

Comparing version 0.8.0-beta.2 to 0.8.0-beta.3

lib/schema-registry.js

@@ -85,2 +85,3 @@ /**
     .map(this._fetchLatestVersion, { concurrency: 10 })
+    .filter(Boolean)
     .map(this._fetchSchema, { concurrency: 10 })
@@ -109,2 +110,3 @@ .map(this._registerSchemaLatest)
       .map(this._fetchAllSchemaVersions, {concurrency: 10})
+      .filter(Boolean)
       .then(this._flatenResults)
@@ -258,3 +260,3 @@ .map(this._fetchSchema, {concurrency: 10})
     })
-    .catch(this._handleAxiosError);
+    .catch(this._suppressAxiosError);
 });
@@ -271,6 +273,2 @@
 SchemaRegistry.prototype._fetchSchema = Promise.method(function (topicMeta) {
-  if (!topicMeta) {
-    // Request failed to fetch a schema for the designated topic, just skip
-    return;
-  }
   var schemaTopic = topicMeta.schemaTopic;
@@ -394,3 +392,3 @@ var version = topicMeta.version;
 SchemaRegistry.prototype._suppressAxiosError = function (err) {
-  if (!err.port) {
+  if (!err.response) {
     // not an axios error, bail early
@@ -397,0 +395,0 @@ throw err;

package.json

 {
   "name": "kafka-avro",
-  "version": "0.8.0-beta.2",
+  "version": "0.8.0-beta.3",
   "main": "./lib/kafka-avro",
@@ -5,0 +5,0 @@ "description": "Node.js bindings for librdkafka with Avro schema serialization.",

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Worsened metrics

Total package byte prevSize

63049

decreased by-0.1%

Lines of code

1394

decreased by-0.14%

No dependency changes