logproxy-client/src/main/java/com/oceanbase/clogproxy/client/LogProxyClient.java

@@ -19,7 +19,6 @@ import com.oceanbase.clogproxy.client.listener.RecordListener;
 import com.oceanbase.clogproxy.client.listener.StatusListener;
 import com.oceanbase.clogproxy.client.util.Validator;
 import com.oceanbase.clogproxy.common.packet.ProtocolVersion;
-import io.netty.handler.ssl.SslContext;
 
 /** A client that makes it easy to connect to log proxy and start a {@link ClientStream}. */
 public class LogProxyClient {
@@ -28,7 +27,7 @@ public class LogProxyClient {
     private final ClientStream stream;
 
     /**
-     * Constructor with {@link SslContext}.
+     * Constructor with {@link ClientConf}.
      *
      * @param host Log proxy hostname name or ip.
      * @param port Log proxy port.
@@ -42,7 +41,8 @@ public class LogProxyClient {
             Validator.notEmpty(host, "server cannot be null");
             Validator.validatePort(port, "port is not valid");
         } catch (Exception e) {
-            throw new IllegalArgumentException("Illegal argument for LogProxyClient");
+            throw new IllegalArgumentException(
+                    "Illegal argument for LogProxyClient: " + e.getMessage());
         }
         if (!config.valid()) {
             throw new IllegalArgumentException("Illegal argument for LogProxyClient");
@@ -59,7 +59,7 @@ public class LogProxyClient {
     }
 
     /**
-     * Constructor without {@link SslContext}.
+     * Constructor without {@link ClientConf}.
      *
      * @param host Log proxy hostname name or ip.
      * @param port Log proxy port.

logproxy-client/src/main/java/com/oceanbase/clogproxy/client/config/ClientConf.java

@@ -22,7 +22,7 @@ public class ClientConf extends SharedConf implements Serializable {
     private static final long serialVersionUID = 1L;
 
     /** Client version. */
-    public static final String VERSION = "1.0.5";
+    public static final String VERSION = "1.0.7";
 
     /** Queue size for storing records received from log proxy. */
     private final int transferQueueSize;