From 4dc4f3afe4b533a57d3d05f2c3d0356da21603f7 Mon Sep 17 00:00:00 2001
From: "furkan.kavraz" <furkan.kavraz@trendyol.com>
Date: Tue, 24 Sep 2024 15:14:50 +0300
Subject: [PATCH] #46 fixes the bug, that keeps running the app alive when
 there is a lag, but no message in the topic partition

---
 .github/workflows/publish.yml                        | 2 +-
 .gitlab-ci.yml                                       | 2 +-
 CHANGELOG.MD                                         | 8 ++++++++
 src/Services/Implementations/KafkaRetryJobService.cs | 2 +-
 4 files changed, 11 insertions(+), 3 deletions(-)

diff --git a/.github/workflows/publish.yml b/.github/workflows/publish.yml
index d8dffe4..6678c05 100644
--- a/.github/workflows/publish.yml
+++ b/.github/workflows/publish.yml
@@ -19,7 +19,7 @@ jobs:
         name: Build & push Docker image
         with:
           image: kafka-retry-job
-          tags: 1.12.4, latest
+          tags: 1.12.5, latest
           registry: ghcr.io
           username: ${{ secrets.GHCR_USERNAME }}
           password: ${{ secrets.GHCR_TOKEN }}
diff --git a/.gitlab-ci.yml b/.gitlab-ci.yml
index 4d48127..a94d2ef 100644
--- a/.gitlab-ci.yml
+++ b/.gitlab-ci.yml
@@ -1,6 +1,6 @@
 
 variables:
-  VERSION: "1.12.4"
+  VERSION: "1.12.5"
   DOCKER_IMAGE_VERSION: $GITLAB_REGISTRY_HOST/$CI_PROJECT_PATH:$VERSION
   DOCKER_IMAGE_LATEST: $GITLAB_REGISTRY_HOST/$CI_PROJECT_PATH
 
diff --git a/CHANGELOG.MD b/CHANGELOG.MD
index f567f63..e323255 100644
--- a/CHANGELOG.MD
+++ b/CHANGELOG.MD
@@ -1,5 +1,13 @@
 # Changelog
 
+## [1.12.5](https://github.com/github-changelog-generator/github-changelog-generator/tree/1.16.4) (2024-03)
+
+- [\#46](https://github.com/Trendyol/kafka-retry-job/issues/46) Fixes the bug that keeps running the app alive when there is a lag, but no message in the topic partition
+
+**Merged pull requests:**
+
+- Pull Request for the issues #46 [\#46](https://github.com/Trendyol/kafka-retry-job/pull/46) ([ahmetfurkankavraz](https://github.com/ahmetfurkankavraz))
+
 ## [1.12.4](https://github.com/github-changelog-generator/github-changelog-generator/tree/1.16.4) (2024-03)
 
 - [\#29](https://github.com/Trendyol/kafka-retry-job/issues/29) Add async programming to consume message in parallel
diff --git a/src/Services/Implementations/KafkaRetryJobService.cs b/src/Services/Implementations/KafkaRetryJobService.cs
index ac0d6ce..e3847b8 100644
--- a/src/Services/Implementations/KafkaRetryJobService.cs
+++ b/src/Services/Implementations/KafkaRetryJobService.cs
@@ -104,7 +104,7 @@ Action<IConsumer<string,string>, ConsumeResult<string,string>> consumerCommitStr
 
                         if (result is null)
                         {
-                            continue;
+                            break;
                         }
 
                         currentLag -= 1;