Sink connector ignores tasks.max argument

[buinauskas]

We've noticed that the sink connector ignores the tasks.max configuration parameter entirely and there's no way to create more sink tasks. I suspect this is due to the following method that always yields a single instance of task, it ignores the numTasks argument entirely.

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

Line 46 in f095f81

return Collections.singletonList(props);

The documentation suggests that it should support it https://redis-field-engineering.github.io/redis-kafka-connect/#_sink_tasks

The Redis Kafka Sink Connector supports running one or more tasks. You can specify the number of tasks with the tasks.max configuration property.

[jruaux]

Thanks you for reporting this and for the fix.

[jruaux]

🎉 This issue has been resolved in v0.9.0 (Release Notes)