deps: Upgraded Lettucemod and Spring Batch Redis

Author: Julien Ruaux

pom.xml

@@ -25,10 +25,10 @@
 		<awaitility.version>4.2.0</awaitility.version>
 		<jruby.version>9.2.17.0</jruby.version>
 		<junit.version>5.8.1</junit.version>
-		<lettucemod.version>2.19.3</lettucemod.version>
+		<lettucemod.version>3.0.0</lettucemod.version>
 		<mockito.version>4.6.1</mockito.version>
-		<reactor.version>3.4.19</reactor.version>
-		<spring-batch-redis.version>2.30.3</spring-batch-redis.version>
+		<reactor.version>3.4.21</reactor.version>
+		<spring-batch-redis.version>2.31.0</spring-batch-redis.version>
 		<spring-batch.version>4.3.6</spring-batch.version>
 		<slf4j.version>1.7.36</slf4j.version>
 		<testcontainers-redis.version>1.6.0</testcontainers-redis.version>

src/test/integration/java/com/redis/kafka/connect/RedisSinkTaskIT.java

@@ -320,7 +320,7 @@ void putTimeSeries(RedisTestContext redis) {
 					new SchemaAndValue(Schema.FLOAT64_SCHEMA, value)));
 		}
 		put(topic, RedisSinkConfig.DataType.TIMESERIES, redis, records);
-		List<Sample> actualSamples = redis.sync().range(topic, TimeRange.unbounded());
+		List<Sample> actualSamples = redis.sync().tsRange(topic, TimeRange.unbounded());
 		assertEquals(expectedSamples.size(), actualSamples.size());
 		for (int index = 0; index < expectedSamples.size(); index++) {
 			Sample expectedSample = expectedSamples.get(index);
@@ -362,8 +362,8 @@ void putRpush(RedisTestContext redis) {
 			records.add(SinkRecordHelper.write(topic, new SchemaAndValue(Schema.STRING_SCHEMA, member),
 					new SchemaAndValue(Schema.STRING_SCHEMA, member)));
 		}
-		put(topic, RedisSinkConfig.DataType.LIST, redis, records,
-				RedisSinkConfig.PUSH_DIRECTION_CONFIG, RedisSinkConfig.PushDirection.RIGHT.name());
+		put(topic, RedisSinkConfig.DataType.LIST, redis, records, RedisSinkConfig.PUSH_DIRECTION_CONFIG,
+				RedisSinkConfig.PushDirection.RIGHT.name());
 		List<String> actual = redis.sync().lrange(topic, 0, -1);
 		assertEquals(expected, actual);
 	}
@@ -477,13 +477,13 @@ void putZset(RedisTestContext context) {
 		assertEquals(expected, actual);
 	}
 
-	public void put(String topic, RedisSinkConfig.DataType type, RedisTestContext context,
-			List<SinkRecord> records, String... props) {
+	public void put(String topic, RedisSinkConfig.DataType type, RedisTestContext context, List<SinkRecord> records,
+			String... props) {
 		SinkTaskContext taskContext = mock(SinkTaskContext.class);
 		when(taskContext.assignment()).thenReturn(ImmutableSet.of(new TopicPartition(topic, 1)));
 		task.initialize(taskContext);
-		Map<String, String> propsMap = map(RedisSinkConfig.URI_CONFIG,
-				context.getServer().getRedisURI(), RedisSinkConfig.TYPE_CONFIG, type.name());
+		Map<String, String> propsMap = map(RedisSinkConfig.URI_CONFIG, context.getServer().getRedisURI(),
+				RedisSinkConfig.TYPE_CONFIG, type.name());
 		propsMap.putAll(map(props));
 		task.start(propsMap);
 		task.put(records);