Log Kafka offset (#1089)

artie-labs · Dec 18, 2024 · 8681910 · 8681910
1 parent aab8d1c
commit 8681910
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 {