diff --git a/filebeat/input/redis/harvester.go b/filebeat/input/redis/harvester.go
index 67854bc04b1..0abfab3485e 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)
 	}