[incubator-plc4x] 01/05: create only one task in source connector

[cd...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

cdutz pushed a commit to branch feature/apache-kafka
in repository https://gitbox.apache.org/repos/asf/incubator-plc4x.git

commit a3625a2a8ba20a8d83c9f3062ccaa4f87f41efc9
Author: Andrey Skorikov <an...@codecentric.de>
AuthorDate: Wed Sep 5 16:15:04 2018 +0200

    create only one task in source connector
---
 .../src/main/java/org/apache/plc4x/kafka/Plc4xSourceConnector.java | 7 +++----
 1 file changed, 3 insertions(+), 4 deletions(-)

diff --git a/integrations/apache-kafka/src/main/java/org/apache/plc4x/kafka/Plc4xSourceConnector.java b/integrations/apache-kafka/src/main/java/org/apache/plc4x/kafka/Plc4xSourceConnector.java
index f20a8a5..06379a6 100644
--- a/integrations/apache-kafka/src/main/java/org/apache/plc4x/kafka/Plc4xSourceConnector.java
+++ b/integrations/apache-kafka/src/main/java/org/apache/plc4x/kafka/Plc4xSourceConnector.java
@@ -28,6 +28,7 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 import java.util.ArrayList;
+import java.util.Collections;
 import java.util.List;
 import java.util.Map;
 
@@ -44,10 +45,8 @@ public class Plc4xSourceConnector extends SourceConnector {
     @Override
     public List<Map<String, String>> taskConfigs(int maxTasks) {
         log.info("Setting task configurations for {} workers.", maxTasks);
-        final List<Map<String, String>> configs = new ArrayList<>(maxTasks);
-        for (int i = 0; i < maxTasks; ++i) {
-            configs.add(configProperties);
-        }
+        // Only one task will be created; ignoring maxTasks for now
+        final List<Map<String, String>> configs = Collections.singletonList(configProperties);
         return configs;
     }