From 0c5c4786521688c5b1ebb87df96c5acdf72d2274 Mon Sep 17 00:00:00 2001 From: Johannes Batzill Date: Wed, 7 Aug 2024 00:15:34 +0000 Subject: [PATCH] add logging for redis history sanning (#2417) --- stream/redis_consumer.go | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/stream/redis_consumer.go b/stream/redis_consumer.go index c436dace6..54f9d9aa0 100644 --- a/stream/redis_consumer.go +++ b/stream/redis_consumer.go @@ -286,6 +286,14 @@ func (c *RedisConsumer) reader(ctx context.Context) { if len(stream.Messages) > 0 { scanHistory = true streamsArg[streamLen+x] = stream.Messages[len(stream.Messages)-1].ID + + c.pushInfo(fmt.Sprintf( + "stream %q had %d more messages in the history (delivered but no yet acked),"+ + "continuing scanning after %q", + stream.Stream, + len(stream.Messages), + streamsArg[streamLen+x], + )) } x++ }