Hotfix: consumer mark message when ConsumeClaim

asheswook · asheswook · commit 07912e2c5a46 · 2024-08-13T20:55:16.000+09:00
diff --git 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
 		}

Original file line number	Diff line number	Diff line change
`@@ -27,6 +27,7 @@ func (c *Consumer) ConsumeClaim(session sarama.ConsumerGroupSession, claim saram`
`27`	`27`
`28`	`28`	`c.callback(msg)`
`29`	`29`
	`30`	`+ session.MarkMessage(msg, "") // sarama internal offset commit, not a kafka commit`
`30`	`31`	`case <-session.Context().Done():`
`31`	`32`	`return nil`
`32`	`33`	`}`