Skip to content

Commit

Permalink
ISSUE-925 Added delete,compact topics config (#926)
Browse files Browse the repository at this point in the history
* ISSUE-925 Added delete,compact topics config

* Fixed checkstyle
  • Loading branch information
germanosin committed Oct 4, 2021
1 parent 81a6564 commit 07a9528
Showing 1 changed file with 15 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -2,27 +2,37 @@

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));
}
Expand Down

0 comments on commit 07a9528

Please sign in to comment.