add logging for redis history sanning (#2417)

2024-08-07 00:15:34 +00:00 · 2024-08-07 00:15:34 +00:00 · 0c5c478652
parent aa24282254
commit 0c5c478652
1 changed files with 8 additions and 0 deletions
--- 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++
 				}