You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@plc4x.apache.org by cd...@apache.org on 2018/09/06 21:14:53 UTC

[incubator-plc4x] 02/05: removed unused import

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 <an...@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;
     }