diff --git a/feed_dns.py b/feed_dns.py
index 3acad9a..5adf770 100755
--- a/feed_dns.py
+++ b/feed_dns.py
@@ -2,7 +2,6 @@
 
 import argparse
 import database
-import json
 import logging
 import sys
 import typing
@@ -66,12 +65,16 @@ class Rapid7Parser(Parser):
     }
 
     def consume(self) -> None:
+        data = dict()
         for line in self.buf:
             self.db.enter_step('parse_rapid7')
-            try:
-                data = json.loads(line)
-            except json.decoder.JSONDecodeError:
-                continue
+            split = line.split('"')
+
+            for k in range(1, 14, 4):
+                key = split[k]
+                val = split[k+2]
+                data[key] = val
+
             self.register(
                 Rapid7Parser.TYPES[data['type']],
                 int(data['timestamp']),