Fixed injection on multiple managed clusters (#209)

Author: Loïc GREFFIER

api/src/main/java/com/michelin/ns4kafka/services/executors/ConnectorAsyncExecutor.java

@@ -27,8 +27,7 @@ public class ConnectorAsyncExecutor {
     /**
      * The managed clusters config
      */
-    @Inject
-    private KafkaAsyncExecutorConfig kafkaAsyncExecutorConfig;
+    private final KafkaAsyncExecutorConfig kafkaAsyncExecutorConfig;
 
     /**
      * The connector repository
@@ -42,6 +41,15 @@ public class ConnectorAsyncExecutor {
     @Inject
     private KafkaConnectClient kafkaConnectClient;
 
+    /**
+     * Constructor
+     * Required to inject multiple
+     * @param kafkaAsyncExecutorConfig The managed clusters config
+     */
+    public ConnectorAsyncExecutor(KafkaAsyncExecutorConfig kafkaAsyncExecutorConfig) {
+        this.kafkaAsyncExecutorConfig = kafkaAsyncExecutorConfig;
+    }
+
     /**
      * Start connector synchronization
      */

api/src/main/java/com/michelin/ns4kafka/services/executors/KafkaAsyncExecutorConfig.java

@@ -1,6 +1,5 @@
 package com.michelin.ns4kafka.services.executors;
 
-
 import io.micronaut.context.annotation.ConfigurationProperties;
 import io.micronaut.context.annotation.EachProperty;
 import io.micronaut.context.annotation.Parameter;
@@ -10,7 +9,6 @@
 import lombok.Setter;
 import org.apache.kafka.clients.admin.Admin;
 
-import java.security.Provider;
 import java.util.Map;
 import java.util.Properties;
 
@@ -21,7 +19,7 @@ public class KafkaAsyncExecutorConfig {
     /**
      * Cluster name
      */
-    private final String name;
+    private String name;
 
     /**
      * Run topics synchronization ?