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 a1b97c4a7e00b368bcf9e55dab6cef973badb351 Author: Andrey Skorikov <andrey.skori...@codecentric.de> AuthorDate: Wed Sep 5 16:19:30 2018 +0200 removed unused import --- .../src/main/java/org/apache/plc4x/kafka/Plc4xSourceConnector.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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 06379a6..4de195b 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 @@ -27,7 +27,6 @@ import org.apache.plc4x.kafka.util.VersionUtil; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import java.util.ArrayList; import java.util.Collections; import java.util.List; import java.util.Map; @@ -45,8 +44,10 @@ public class Plc4xSourceConnector extends SourceConnector { @Override public List<Map<String, String>> taskConfigs(int maxTasks) { log.info("Setting task configurations for {} workers.", maxTasks); + // Only one task will be created; ignoring maxTasks for now final List<Map<String, String>> configs = Collections.singletonList(configProperties); + return configs; }