Log.

artie-labs · Dec 18, 2024 · 1d5117f · 1d5117f
1 parent 8895e57
commit 1d5117f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/processes/consumer/configs.go b/processes/consumer/configs.go
@@ -47,7 +47,7 @@ func commitOffset(ctx context.Context, topic string, partitionsToOffset map[stri
 					return err
 				}
 
-				slog.Info("Committing offset", slog.String("topic", topic), slog.Int("partition", msg.KafkaMsg.Partition), slog.Int64("offset", msg.KafkaMsg.Offset))
+				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 {