changing offset reset to latest

port-labs · Dec 14, 2023 · 7498948 · 7498948
1 parent 1db8ded
commit 7498948
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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 {