Merge branch 'master' into additional-string-converters

artie-labs · Dec 18, 2024 · ace5a06 · ace5a06
2 parents b3cd738 + 8681910
commit ace5a06
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/processes/consumer/configs.go b/processes/consumer/configs.go
@@ -2,6 +2,7 @@ package consumer
 
 import (
 	"context"
+	"log/slog"
 	"sync"
 
 	"github.com/artie-labs/transfer/lib/artie"
@@ -45,6 +46,8 @@ func commitOffset(ctx context.Context, topic string, partitionsToOffset map[stri
 				if err := topicToConsumer.Get(topic).CommitMessages(ctx, *msg.KafkaMsg); err != nil {
 					return err
 				}
+
+				slog.Info("Successfully committed Kafka offset", slog.String("topic", topic), slog.Int("partition", msg.KafkaMsg.Partition), slog.Int64("offset", msg.KafkaMsg.Offset))
 			}
 
 			if msg.PubSub != nil {