diff --git a/src/main/java/io/lettuce/core/json/DefaultJsonParser.java b/src/main/java/io/lettuce/core/json/DefaultJsonParser.java
index dd20fa41ca..8348e54e33 100644
--- a/src/main/java/io/lettuce/core/json/DefaultJsonParser.java
+++ b/src/main/java/io/lettuce/core/json/DefaultJsonParser.java
@@ -25,6 +25,27 @@
  */
 public class DefaultJsonParser implements JsonParser {
 
+    private final ObjectMapper objectMapper;
+
+    /**
+     * Create a new instance of the {@link DefaultJsonParser} initialing a {@link ObjectMapper} with defaults.
+     */
+    public DefaultJsonParser() {
+        objectMapper = new ObjectMapper();
+    }
+
+    /**
+     * Create a new instance of the {@link DefaultJsonParser} using the provided {@link ObjectMapper}.
+     *
+     * @param objectMapper the {@link ObjectMapper} to use
+     */
+    public DefaultJsonParser(ObjectMapper objectMapper) {
+        if (objectMapper == null) {
+            throw new IllegalArgumentException("ObjectMapper must not be null");
+        }
+        this.objectMapper = objectMapper;
+    }
+
     @Override
     public JsonValue loadJsonValue(ByteBuffer bytes) {
         return new UnproccessedJsonValue(bytes, this);
@@ -52,7 +73,6 @@ public JsonArray createJsonArray() {
 
     @Override
     public JsonValue fromObject(Object object) {
-        ObjectMapper objectMapper = new ObjectMapper();
         try {
             JsonNode root = objectMapper.valueToTree(object);
             return DelegateJsonValue.wrap(root);
@@ -66,9 +86,8 @@ private JsonValue parse(String value) {
             return DelegateJsonValue.wrap(NullNode.getInstance());
         }
 
-        ObjectMapper mapper = new ObjectMapper();
         try {
-            JsonNode root = mapper.readTree(value);
+            JsonNode root = objectMapper.readTree(value);
             return DelegateJsonValue.wrap(root);
         } catch (JsonProcessingException e) {
             throw new RedisJsonException(
@@ -81,11 +100,10 @@ private JsonValue parse(ByteBuffer byteBuffer) {
             return DelegateJsonValue.wrap(NullNode.getInstance());
         }
 
-        ObjectMapper mapper = new ObjectMapper();
         try {
             byte[] bytes = new byte[byteBuffer.remaining()];
             byteBuffer.get(bytes);
-            JsonNode root = mapper.readTree(bytes);
+            JsonNode root = objectMapper.readTree(bytes);
             return DelegateJsonValue.wrap(root);
         } catch (IOException e) {
             throw new RedisJsonException("Failed to process the provided value as JSON", e);