fix: take into account the maxTasks config parameter.

Fixes #27

Author: jruaux

core/redis-kafka-connect/src/main/java/com/redis/kafka/connect/RedisSinkConnector.java

@@ -15,10 +15,9 @@
  */
 package com.redis.kafka.connect;
 
+import java.util.Collections;
 import java.util.List;
 import java.util.Map;
-import java.util.stream.Collectors;
-import java.util.stream.IntStream;
 
 import org.apache.kafka.common.config.ConfigDef;
 import org.apache.kafka.connect.connector.Task;
@@ -44,7 +43,7 @@ public Class<? extends Task> taskClass() {
 
     @Override
     public List<Map<String, String>> taskConfigs(int maxTasks) {
-        return IntStream.range(0, maxTasks).mapToObj(i -> props).collect(Collectors.toList());
+        return Collections.nCopies(maxTasks, props);
     }
 
     @Override

core/redis-kafka-connect/src/test/java/com/redis/kafka/connect/SinkConnectorTest.java

@@ -28,7 +28,9 @@ void testTaskConfigs() {
 		HashMap<String, String> props = new HashMap<>();
 		props.put("field1", "value1");
 		connector.start(props);
-		Assertions.assertEquals(props, connector.taskConfigs(123).get(0));
+		int maxTasks = 123;
+		Assertions.assertEquals(props, connector.taskConfigs(maxTasks).get(0));
+		Assertions.assertEquals(maxTasks, connector.taskConfigs(maxTasks).size());
 	}
 
 	@Test