Bläddra i källkod

ISSUE-925 Added delete,compact topics config (#926)

* ISSUE-925 Added delete,compact topics config

* Fixed checkstyle
German Osin 3 år sedan
förälder
incheckning
07a9528d39

+ 15 - 5
kafka-ui-api/src/main/java/com/provectus/kafka/ui/model/CleanupPolicy.java

@@ -2,27 +2,37 @@ package com.provectus.kafka.ui.model;
 
 import com.provectus.kafka.ui.exception.IllegalEntityStateException;
 import java.util.Arrays;
+import java.util.Collections;
+import java.util.List;
 
 public enum CleanupPolicy {
   DELETE("delete"),
   COMPACT("compact"),
-  COMPACT_DELETE("compact,delete"),
+  COMPACT_DELETE(Arrays.asList("compact,delete", "delete,compact")),
   UNKNOWN("unknown");
 
-  private final String cleanUpPolicy;
+  private final List<String> cleanUpPolicy;
 
   CleanupPolicy(String cleanUpPolicy) {
+    this(Collections.singletonList(cleanUpPolicy));
+  }
+
+  CleanupPolicy(List<String> cleanUpPolicy) {
     this.cleanUpPolicy = cleanUpPolicy;
   }
 
   public String getCleanUpPolicy() {
-    return cleanUpPolicy;
+    return cleanUpPolicy.get(0);
   }
 
   public static CleanupPolicy fromString(String string) {
     return Arrays.stream(CleanupPolicy.values())
-        .filter(v -> v.cleanUpPolicy.equals(string.replace(" ", "")))
-        .findFirst()
+        .filter(v ->
+            v.cleanUpPolicy.stream().anyMatch(
+                s -> s.equals(string.replace(" ", "")
+                )
+            )
+        ).findFirst()
         .orElseThrow(() ->
             new IllegalEntityStateException("Unknown cleanup policy value: " + string));
   }