Return true when RD_KAFKA_RESP_ERR__NO_OFFSET is received

This commit is contained in:
Alexander Damian
2019-04-24 17:39:59 -04:00
parent effdf7fb95
commit 81a131ff16

View File

@@ -147,9 +147,9 @@ private:
catch (const HandleException& ex) {
Error error = ex.get_error();
// If there were actually no offsets to commit, return. Retrying won't solve
// anything here
// anything here.
if (error == RD_KAFKA_RESP_ERR__NO_OFFSET) {
throw ex; //abort
return true; //not considered an error.
}
// If there's a callback and it returns false for this message, abort.
// Otherwise keep committing.