Add ignore error in commit messages

joesantos418 · Jun 24, 2019 · 4d3594c · 4d3594c
1 parent 61ce596
commit 4d3594c
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/src/Consumer.php b/src/Consumer.php
@@ -118,20 +118,22 @@ private function commit(\RdKafka\Message $message, bool $success): void
         try {
             if (!$success && !is_null($this->config->getDlq())) {
                 $this->sendToDql($message);
-                $this->consumer->commit();
                 $this->commits = 0;
+                $this->consumer->commit();
                 return;
             }
 
             $this->commits++;
             if ($this->isMaxMessage() || $this->commits >= $this->config->getCommit()) {
-                $this->consumer->commit();
                 $this->commits = 0;
+                $this->consumer->commit();
                 return;
             }
         } catch (\Throwable $throwable) {
             $this->logger->error($message, $throwable, 'MESSAGE_COMMIT');
-            throw $throwable;
+            if ($throwable->getCode() != RD_KAFKA_RESP_ERR__NO_OFFSET){
+                throw $throwable;
+            }
         }
     }