From 74989485107c5109a01e8059b496b5a2b157e666 Mon Sep 17 00:00:00 2001
From: yair <yairsimantov20@gmail.com>
Date: Thu, 14 Dec 2023 13:38:04 +0200
Subject: [PATCH] changing offset reset to latest

---
 pkg/event_listener/consumer/consumer.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/pkg/event_listener/consumer/consumer.go b/pkg/event_listener/consumer/consumer.go
index 9a82e15..2f9a574 100644
--- a/pkg/event_listener/consumer/consumer.go
+++ b/pkg/event_listener/consumer/consumer.go
@@ -23,7 +23,7 @@ func NewConsumer(config *config.KafkaConfiguration) (*Consumer, error) {
 		"sasl.mechanism":    config.AuthenticationMechanism,
 		"sasl.username":     config.Username,
 		"sasl.password":     config.Password,
-		"auto.offset.reset": "earliest",
+		"auto.offset.reset": "latest",
 	})
 
 	if err != nil {