|
@@ -4,12 +4,10 @@ import static java.util.stream.Collectors.toList;
|
|
import static java.util.stream.Collectors.toMap;
|
|
import static java.util.stream.Collectors.toMap;
|
|
import static org.apache.kafka.clients.admin.ListOffsetsResult.ListOffsetsResultInfo;
|
|
import static org.apache.kafka.clients.admin.ListOffsetsResult.ListOffsetsResultInfo;
|
|
|
|
|
|
|
|
+import com.google.common.base.Preconditions;
|
|
import com.google.common.collect.ImmutableTable;
|
|
import com.google.common.collect.ImmutableTable;
|
|
import com.google.common.collect.Iterables;
|
|
import com.google.common.collect.Iterables;
|
|
import com.google.common.collect.Table;
|
|
import com.google.common.collect.Table;
|
|
-import com.google.common.base.Preconditions;
|
|
|
|
-import com.google.common.collect.ImmutableMap;
|
|
|
|
-import com.google.common.collect.Iterators;
|
|
|
|
import com.provectus.kafka.ui.exception.IllegalEntityStateException;
|
|
import com.provectus.kafka.ui.exception.IllegalEntityStateException;
|
|
import com.provectus.kafka.ui.exception.NotFoundException;
|
|
import com.provectus.kafka.ui.exception.NotFoundException;
|
|
import com.provectus.kafka.ui.exception.ValidationException;
|
|
import com.provectus.kafka.ui.exception.ValidationException;
|
|
@@ -17,7 +15,6 @@ import com.provectus.kafka.ui.util.NumberUtil;
|
|
import com.provectus.kafka.ui.util.annotation.KafkaClientInternalsDependant;
|
|
import com.provectus.kafka.ui.util.annotation.KafkaClientInternalsDependant;
|
|
import java.io.Closeable;
|
|
import java.io.Closeable;
|
|
import java.util.ArrayList;
|
|
import java.util.ArrayList;
|
|
-import java.util.Arrays;
|
|
|
|
import java.util.Collection;
|
|
import java.util.Collection;
|
|
import java.util.HashMap;
|
|
import java.util.HashMap;
|
|
import java.util.HashSet;
|
|
import java.util.HashSet;
|