DBZ-4733 Refactor ReplicaSets.parse into more readable form
This commit is contained in:
parent
752062c1a3
commit
21ed5f9b9f
@ -9,13 +9,14 @@
|
|||||||
import java.util.Collection;
|
import java.util.Collection;
|
||||||
import java.util.Collections;
|
import java.util.Collections;
|
||||||
import java.util.HashMap;
|
import java.util.HashMap;
|
||||||
import java.util.HashSet;
|
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
import java.util.Objects;
|
import java.util.Objects;
|
||||||
import java.util.Set;
|
import java.util.Set;
|
||||||
import java.util.function.Consumer;
|
import java.util.function.Consumer;
|
||||||
import java.util.regex.Pattern;
|
import java.util.regex.Pattern;
|
||||||
|
import java.util.stream.Collectors;
|
||||||
|
import java.util.stream.Stream;
|
||||||
|
|
||||||
import org.apache.kafka.connect.util.ConnectorUtils;
|
import org.apache.kafka.connect.util.ConnectorUtils;
|
||||||
|
|
||||||
@ -43,20 +44,24 @@ public class ReplicaSets {
|
|||||||
* @see ReplicaSets#hosts()
|
* @see ReplicaSets#hosts()
|
||||||
*/
|
*/
|
||||||
public static ReplicaSets parse(String hosts) {
|
public static ReplicaSets parse(String hosts) {
|
||||||
Set<ReplicaSet> replicaSets = new HashSet<>();
|
Set<ReplicaSet> replicaSets = splitHosts(hosts).stream()
|
||||||
if (hosts != null) {
|
.map(ReplicaSet::parse)
|
||||||
for (String replicaSetStr : REPLICA_DELIMITER_PATTERN.split(hosts.trim())) {
|
.filter(Objects::nonNull)
|
||||||
if (!replicaSetStr.isEmpty()) {
|
.collect(Collectors.toSet());
|
||||||
ReplicaSet replicaSet = ReplicaSet.parse(replicaSetStr);
|
|
||||||
if (replicaSetStr != null) {
|
|
||||||
replicaSets.add(replicaSet);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return new ReplicaSets(replicaSets);
|
return new ReplicaSets(replicaSets);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public static List<String> splitHosts(String hosts) {
|
||||||
|
if (hosts == null) {
|
||||||
|
return List.of();
|
||||||
|
}
|
||||||
|
return Stream.of(REPLICA_DELIMITER_PATTERN
|
||||||
|
.split(hosts.trim()))
|
||||||
|
.filter(h -> !h.isBlank())
|
||||||
|
.collect(Collectors.toList());
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Get an instance that contains no replica sets.
|
* Get an instance that contains no replica sets.
|
||||||
*
|
*
|
||||||
|
Loading…
Reference in New Issue
Block a user