Wire Kafka Connect client configuration properties

Author: lmj

metadata-service/src/main/java/com/dbsyncer/metadata/config/ConnectClientConfiguration.java

@@ -0,0 +1,15 @@
+package com.dbsyncer.metadata.config;
+
+import com.dbsyncer.connectors.client.KafkaConnectClient;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class ConnectClientConfiguration {
+
+    @Bean(destroyMethod = "close")
+    public KafkaConnectClient kafkaConnectClient(ConnectProperties props) {
+        return new KafkaConnectClient(props.getRestUrl());
+    }
+}
+

metadata-service/src/main/java/com/dbsyncer/metadata/config/ConnectProperties.java

@@ -0,0 +1,17 @@
+package com.dbsyncer.metadata.config;
+
+import lombok.Getter;
+import lombok.Setter;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+@ConfigurationProperties(prefix = "connect")
+@Getter
+@Setter
+public class ConnectProperties {
+    private String restUrl;
+    private long waitTimeoutMs = 60000;
+    private long pollIntervalMs = 2000;
+}
+