Added logic to detect connector class(MySQL or PostgreSQL) and change…

… log messages.

sink-connector/src/main/java/com/altinity/clickhouse/sink/connector/common/ConnectorType.java

@@ -0,0 +1,26 @@
+package com.altinity.clickhouse.sink.connector.common;
+
+import io.debezium.metadata.ConnectorDescriptor;
+
+
+
+    public enum ConnectorType {      
+        MYSQL("mysql"),
+        POSTGRES("postgres");
+
+        private final String value;
+
+        ConnectorType(String value) {
+            this.value = value;
+        }
+
+        public String getValue() {
+            return value;
+        }
+
+        public static ConnectorType fromString(String value) {
+
+            ConnectorDescriptor.getDisplayNameForConnectorClass(value);
+            return ConnectorType.valueOf(value);
+        }
+    }