- 去除isReachable验证

- 查询topic数据时增加分页

Author: dushixiang

pom.xml

@@ -10,7 +10,7 @@
     </parent>
     <groupId>cn.typesafe</groupId>
     <artifactId>kafka-map</artifactId>
-    <version>1.1.1</version>
+    <version>1.1.2</version>
     <name>kafka-map</name>
     <description>a simple kafka manager</description>
     <properties>

src/main/java/cn/typesafe/km/service/ClusterService.java

@@ -107,12 +107,8 @@ public void create(Cluster cluster) throws ExecutionException, InterruptedExcept
         for (String server : cluster.getServers().split(",")) {
             String[] split = server.split(":");
             String host = split[0];
-            boolean hostReachable = Networks.isHostReachable(host);
-            if (!hostReachable) {
-                throw new IllegalArgumentException("Host " + host + " is not reachable.");
-            }
             int port = Integer.parseInt(split[1]);
-            boolean hostConnected = Networks.isHostConnected(host, port);
+            boolean hostConnected = Networks.isHostConnected(host, port, 30000);
             if (!hostConnected) {
                 throw new IllegalArgumentException("server " + server + " can't connected.");
             }

src/main/java/cn/typesafe/km/util/Networks.java

@@ -7,18 +7,18 @@
 
 public class Networks {
 
-    public static boolean isHostReachable(String host) {
+    public static boolean isHostReachable(String host, int timeout) {
         try {
-            return InetAddress.getByName(host).isReachable(1000);
+            return InetAddress.getByName(host).isReachable(timeout);
         } catch (IOException ignored) {
 
         }
         return false;
     }
 
-    public static boolean isHostConnected(String host, int port) {
+    public static boolean isHostConnected(String host, int port, int timeout) {
         try (Socket socket = new Socket()) {
-            socket.connect(new InetSocketAddress(host, port), 3000);
+            socket.connect(new InetSocketAddress(host, port), timeout);
 //            InetAddress localAddress = socket.getLocalAddress();
 //            String hostName = localAddress.getHostName();
             return true;

web/package.json

@@ -1,6 +1,6 @@
 {
   "name": "kafka-map",
-  "version": "1.1.1",
+  "version": "1.1.2",
   "private": true,
   "dependencies": {
     "@testing-library/jest-dom": "^5.11.4",

web/src/components/TopicData.js

@@ -255,6 +255,11 @@ class TopicData extends Component {
                         itemLayout="horizontal"
                         dataSource={this.state.items}
                         loading={this.state.loading}
+                        pagination={{
+                            showSizeChanger: true,
+                            total: this.state.items.length,
+                            showTotal: total => <FormattedMessage id="total-items" values={{total}}/>
+                        }}
                         renderItem={(item, index) => {
                             const title = <>
                                 <Space>
@@ -304,7 +309,6 @@ class TopicData extends Component {
                                 </Col>
                             </Row>;
 
-
                             return <List.Item>
                                 <List.Item.Meta
                                     title={title}