From 1d5117f1e0cae2d61fbc770427438fe23dc15350 Mon Sep 17 00:00:00 2001 From: Robin Tang Date: Wed, 18 Dec 2024 10:19:24 -0800 Subject: [PATCH] Log. --- processes/consumer/configs.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/processes/consumer/configs.go b/processes/consumer/configs.go index 203b10b0..88982040 100644 --- 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 {