diff --git a/target_singer_jsonl/__init__.py b/target_singer_jsonl/__init__.py
index 71bd94f..f5b7793 100644
--- a/target_singer_jsonl/__init__.py
+++ b/target_singer_jsonl/__init__.py
@@ -113,7 +113,10 @@ def persist_lines(config, lines):
     # Loop over lines from stdin
     for line in lines:
         try:
-            message = json.loads(line)
+            message = json.loads(
+                line,
+                parse_float=decimal.Decimal,
+            )
         except json.decoder.JSONDecodeError:
             logger.error(f"Unable to parse:\n{line}")
             raise