Comparing version 3.2.8 to 3.2.9
@@ -95,3 +95,3 @@ 'use strict'; | ||
self.client.warn('Updating offset because of OffsetOutOfRange error for', topic + ':' + partition); | ||
return self.client.getPartitionOffset(s.leader, topic, partition, null, self.options.recoveryOffset).then(function (offset) { | ||
return self.client.getPartitionOffset(s.leader, topic, partition, self.options.recoveryOffset).then(function (offset) { | ||
s.offset = offset; | ||
@@ -98,0 +98,0 @@ }); |
@@ -9,3 +9,3 @@ { | ||
}, | ||
"version": "3.2.8", | ||
"version": "3.2.9", | ||
"main": "./lib/index.js", | ||
@@ -12,0 +12,0 @@ "types": "./types/index.d.ts", |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
356611