From c116c6db518319ae0195c64cfc69af017f6011ff Mon Sep 17 00:00:00 2001 From: Joseph Heyburn Date: Mon, 6 Jan 2025 18:16:09 +0000 Subject: [PATCH] Correctly parse Redis role values in connection receive --- filebeat/input/redis/harvester.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/filebeat/input/redis/harvester.go b/filebeat/input/redis/harvester.go index 67854bc04b11..0abfab3485e7 100644 --- a/filebeat/input/redis/harvester.go +++ b/filebeat/input/redis/harvester.go @@ -108,7 +108,7 @@ func (h *Harvester) Run() error { } // Read reply from ROLE - role, err := h.conn.Receive() + role, err := rd.Values(h.conn.Receive()) if err != nil { return fmt.Errorf("error receiving replication role: %w", err) }