Revert "[NA] [BE] Bump org.redisson:redisson from 3.52.0 to 4.0.0 in /apps/op…" (#4682)

This reverts commit d39ec5b.

Author: thiagohora

apps/opik-backend/config.yml

@@ -129,9 +129,6 @@ redis:
   # Default: redis://:opik@localhost:6379/0
   # Description: single node redis's URL
   singleNodeUrl: ${REDIS_URL:-redis://:opik@localhost:6379/0}
-  # Default: 3
-  # Description: Number of retry attempts for Redis operations
-  retryAttempts: ${REDIS_RETRY_ATTEMPTS:-3}
   # AWS IAM authentication configuration (optional)
   # When enabled, takes precedence over singleNodeUrl authentication
   awsIamAuth:

apps/opik-backend/pom.xml

@@ -30,7 +30,7 @@
         <testcontainers.version>2.0.2</testcontainers.version>
         <uuid.java.generator.version>5.2.0</uuid.java.generator.version>
         <wiremock.version>3.13.1</wiremock.version>
-        <redisson.version>4.0.0</redisson.version>
+        <redisson.version>3.52.0</redisson.version>
         <opentelmetry.version>2.23.0</opentelmetry.version>
         <aws.java.sdk.version>2.40.3</aws.java.sdk.version>
         <json-path.version>2.10.0</json-path.version>

apps/opik-backend/src/main/java/com/comet/opik/api/resources/v1/events/BaseRedisSubscriber.java

@@ -11,13 +11,13 @@
 import lombok.Getter;
 import lombok.NonNull;
 import org.apache.commons.collections4.CollectionUtils;
+import org.redisson.api.AutoClaimResult;
+import org.redisson.api.PendingEntry;
 import org.redisson.api.RStreamReactive;
 import org.redisson.api.RedissonReactiveClient;
+import org.redisson.api.StreamMessageId;
 import org.redisson.api.options.PlainOptions;
-import org.redisson.api.stream.AutoClaimResult;
-import org.redisson.api.stream.PendingEntry;
 import org.redisson.api.stream.StreamCreateGroupArgs;
-import org.redisson.api.stream.StreamMessageId;
 import org.redisson.api.stream.StreamPendingRangeArgs;
 import org.redisson.api.stream.StreamReadGroupArgs;
 import org.slf4j.Logger;

apps/opik-backend/src/main/java/com/comet/opik/infrastructure/RedisConfig.java

@@ -27,19 +27,13 @@ public class RedisConfig {
     @Valid @JsonProperty
     private AwsIamAuthConfig awsIamAuth = new AwsIamAuthConfig();
 
-    @Valid @JsonProperty
-    private Integer retryAttempts;
-
     public Config build() {
         Objects.requireNonNull(singleNodeUrl, "singleNodeUrl must not be null");
         var redisUrl = RedisUrl.parse(singleNodeUrl);
         var config = new Config();
         var singleServerConfig = config.useSingleServer()
                 .setAddress(redisUrl.address())
                 .setDatabase(redisUrl.database());
-        if (retryAttempts != null) {
-            singleServerConfig.setRetryAttempts(retryAttempts);
-        }
         if (awsIamAuth.isEnabled()) {
             // Configure Redis with AWS IAM authentication using DefaultCredentialsProvider
             // This will read from environment variables, system properties, IAM roles, etc.

apps/opik-backend/src/main/java/com/comet/opik/infrastructure/redis/RedisHealthCheck.java

@@ -4,20 +4,19 @@
 import jakarta.inject.Singleton;
 import lombok.NonNull;
 import lombok.RequiredArgsConstructor;
-import org.redisson.api.RedissonClient;
-import org.redisson.api.redisnode.RedisNodes;
+import org.redisson.api.RedissonReactiveClient;
 import ru.vyarus.dropwizard.guice.module.installer.feature.health.NamedHealthCheck;
 
 @Singleton
 @RequiredArgsConstructor(onConstructor_ = @Inject)
 public class RedisHealthCheck extends NamedHealthCheck {
 
-    private final @NonNull RedissonClient redisClient;
+    private final @NonNull RedissonReactiveClient redisClient;
 
     @Override
     protected Result check() {
         try {
-            if (redisClient.getRedisNodes(RedisNodes.SINGLE).pingAll()) {
+            if (redisClient.getNodesGroup().pingAll()) {
                 return Result.healthy();
             }
         } catch (Exception ex) {

apps/opik-backend/src/test/java/com/comet/opik/api/resources/v1/events/BaseRedisSubscriberTest.java

@@ -13,9 +13,9 @@
 import org.redisson.Redisson;
 import org.redisson.api.RStreamReactive;
 import org.redisson.api.RedissonReactiveClient;
+import org.redisson.api.StreamMessageId;
 import org.redisson.api.stream.StreamAddArgs;
 import org.redisson.api.stream.StreamCreateGroupArgs;
-import org.redisson.api.stream.StreamMessageId;
 import org.redisson.api.stream.StreamReadGroupArgs;
 import org.redisson.codec.JsonJacksonCodec;
 import org.redisson.config.Config;
@@ -63,8 +63,7 @@ void setUpAll() {
         var redissonConfig = new Config();
         redissonConfig.useSingleServer()
                 .setAddress(redis.getRedisURI())
-                .setDatabase(0)
-                .setRetryAttempts(0); // Disable retries for faster test execution
+                .setDatabase(0);
         redissonConfig.setCodec(new JsonJacksonCodec(JsonUtils.getMapper()));
         redissonClient = Redisson.create(redissonConfig).reactive();
 

apps/opik-backend/src/test/java/com/comet/opik/api/resources/v1/events/BaseRedisSubscriberUnitTest.java

@@ -9,12 +9,12 @@
 import org.junit.jupiter.api.extension.ExtendWith;
 import org.mockito.Mock;
 import org.mockito.junit.jupiter.MockitoExtension;
+import org.redisson.api.AutoClaimResult;
 import org.redisson.api.RStreamReactive;
 import org.redisson.api.RedissonReactiveClient;
+import org.redisson.api.StreamMessageId;
 import org.redisson.api.options.PlainOptions;
-import org.redisson.api.stream.AutoClaimResult;
 import org.redisson.api.stream.StreamCreateGroupArgs;
-import org.redisson.api.stream.StreamMessageId;
 import org.redisson.api.stream.StreamPendingRangeArgs;
 import org.redisson.api.stream.StreamReadGroupArgs;
 import reactor.core.publisher.Mono;

apps/opik-backend/src/test/resources/config-test.yml

@@ -113,8 +113,6 @@ redis:
   # Default: redis://:opik@localhost:6379/0
   # Description: single node redis's URL
   singleNodeUrl: redis://:opik@localhost:6379/0
-  # Disable retries for faster test execution
-  retryAttempts: 0
 
 openTelemetry:
   # Default: 3h
@@ -559,6 +557,7 @@ webhook:
   poolingInterval: 1s
   # Default: 5s
   # Description: Timeout for blocking read operations on Redis streams (long polling duration)
+  # Note: In tests, set this <= poolingInterval to avoid backpressure drops
   longPollingDuration: 500ms
   # Default: 3
   # Description: Maximum number of retry attempts for failed webhooks (1-10)