Fix broken deserial

michelin · Mar 23, 2024 · 9c3027c · 9c3027c
1 parent 06b43a1
commit 9c3027c
Showing 1 changed file with 19 additions and 1 deletion.
diff --git a/src/main/java/com/michelin/kafkactl/model/Status.java b/src/main/java/com/michelin/kafkactl/model/Status.java
@@ -1,5 +1,6 @@
 package com.michelin.kafkactl.model;
 
+import com.fasterxml.jackson.annotation.JsonCreator;
 import io.micronaut.core.annotation.ReflectiveAccess;
 import java.util.List;
 import lombok.AllArgsConstructor;
@@ -31,7 +32,24 @@ public class Status {
      */
     public enum StatusPhase {
         SUCCESS,
-        FAILED
+        FAILED;
+
+        /**
+         * Build status phase from string.
+         * This is because Ns4Kafka returns capitalised status phases.
+         *
+         * @param key the key
+         * @return the status phase
+         */
+        @JsonCreator
+        public static StatusPhase fromString(String key) {
+            for (StatusPhase type : StatusPhase.values()) {
+                if (type.name().equalsIgnoreCase(key)) {
+                    return type;
+                }
+            }
+            return null;
+        }
     }
 
     /**