Update apache-kafka-2/src/main/java/com/baeldung/kafka/message/ordering/serialization/JacksonDeserializer.java

Co-authored-by: Liam Williams <liam.williams@zoho.com>
2023-11-04 16:56:47 -04:00
parent d4842ac511
commit aeb5f55e0e
1 changed files with 1 additions and 2 deletions
@@ -33,9 +33,8 @@ public class JacksonDeserializer<T> implements Deserializer<T> {
        try {
            return objectMapper.readValue(bytes, type);
        } catch (Exception e) {
-            //throw new RuntimeException("Error deserializing value", e);
+            throw new RuntimeException("Error deserializing value", e);
        }
-        return null;
    }
 }