Comparing version 3.4.2 to 3.4.3
@@ -108,3 +108,6 @@ 'use strict'; | ||
failed = _.filter(_data, { topic: p.topic, partition: p.partition }); | ||
failed = _.map(failed, function (f) { f.error = p.error; }); | ||
failed = _.map(failed, function (f) { | ||
f.error = p.error; | ||
return f; | ||
}); | ||
toRetry = toRetry.concat(failed); | ||
@@ -111,0 +114,0 @@ } else { |
@@ -9,3 +9,3 @@ { | ||
}, | ||
"version": "3.4.2", | ||
"version": "3.4.3", | ||
"main": "./lib/index.js", | ||
@@ -12,0 +12,0 @@ "types": "./types/index.d.ts", |
Sorry, the diff of this file is not supported yet
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
371289
5997