From 07912e2c5a461c6e3fa9cb47c267ff486d49322d Mon Sep 17 00:00:00 2001
From: Jaewook Lee <wookboy00@naver.com>
Date: Tue, 13 Aug 2024 20:55:16 +0900
Subject: [PATCH] Hotfix: consumer mark message when ConsumeClaim

---
 internal/queue/kafka/consumer.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/internal/queue/kafka/consumer.go b/internal/queue/kafka/consumer.go
index efd202b..6839402 100644
--- a/internal/queue/kafka/consumer.go
+++ b/internal/queue/kafka/consumer.go
@@ -27,6 +27,7 @@ func (c *Consumer) ConsumeClaim(session sarama.ConsumerGroupSession, claim saram
 
 			c.callback(msg)
 
+			session.MarkMessage(msg, "") // sarama internal offset commit, not a kafka commit
 		case <-session.Context().Done():
 			return nil
 		}