fix: Added UUID name for keys source task reader

redis-field-engineering · Oct 31, 2024 · d0f63d2 · d0f63d2
1 parent 2674632
commit d0f63d2
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/...redis-kafka-connect/src/main/java/com/redis/kafka/connect/source/RedisKeysSourceTask.java b/...redis-kafka-connect/src/main/java/com/redis/kafka/connect/source/RedisKeysSourceTask.java
@@ -20,6 +20,7 @@
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
+import java.util.UUID;
 
 import org.apache.kafka.connect.data.Schema;
 import org.apache.kafka.connect.errors.ConnectException;
@@ -77,6 +78,8 @@ public void start(Map<String, String> props) {
 		this.batchSize = Math.toIntExact(config.getBatchSize());
 		this.client = config.client();
 		reader = RedisItemReader.struct();
+		// Use a random job name to not interfere with other key source tasks
+		reader.setName(UUID.randomUUID().toString());
 		reader.setClient(client);
 		reader.setMode(ReaderMode.LIVE);
 		reader.setPoolSize(config.getPoolSize());