Skip to content

Commit 81a131f

Browse files
author
Alexander Damian
committed
Return true when RD_KAFKA_RESP_ERR__NO_OFFSET is received
1 parent effdf7f commit 81a131f

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

include/cppkafka/utils/backoff_committer.h

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -147,9 +147,9 @@ class CPPKAFKA_API BackoffCommitter : public BackoffPerformer {
147147
catch (const HandleException& ex) {
148148
Error error = ex.get_error();
149149
// If there were actually no offsets to commit, return. Retrying won't solve
150-
// anything here
150+
// anything here.
151151
if (error == RD_KAFKA_RESP_ERR__NO_OFFSET) {
152-
throw ex; //abort
152+
return true; //not considered an error.
153153
}
154154
// If there's a callback and it returns false for this message, abort.
155155
// Otherwise keep committing.

0 commit comments

Comments
 (0)