Don't keep looping on NO_OFFSET error on backoff committer

This commit is contained in:
Matias Fontanini
2017-08-03 09:33:09 -07:00
parent 1582f6156d
commit 0d4b9ef2f6

View File

@@ -126,6 +126,11 @@ private:
return true;
}
catch (const HandleException& ex) {
// If there were actually no offsets to commit, return. Retrying won't solve
// anything here
if (ex.get_error() == RD_KAFKA_RESP_ERR__NO_OFFSET) {
return true;
}
// If there's a callback and it returns false for this message, abort
if (callback_ && !callback_(ex.get_error())) {
return true;