Fixed mockito

Author: alex268

topic/pom.xml

@@ -48,7 +48,7 @@
         </dependency>
         <dependency>
             <groupId>org.mockito</groupId>
-            <artifactId>mockito-inline</artifactId>
+            <artifactId>mockito-core</artifactId>
             <scope>test</scope>
         </dependency>
         <dependency>
@@ -62,4 +62,26 @@
             <scope>test</scope>
         </dependency>
     </dependencies>
+
+    <profiles>
+        <profile>
+            <id>jdk8-build</id>
+            <activation>
+                <jdk>1.8</jdk>
+            </activation>
+
+            <properties>
+                <!-- Downgrade Mockito to 4 version -->
+                <mockito.version>4.11.0</mockito.version>
+            </properties>
+
+            <dependencies>
+                <dependency>
+                    <groupId>org.mockito</groupId>
+                    <artifactId>mockito-inline</artifactId>
+                    <version>${mockito.version}</version>
+                </dependency>
+            </dependencies>
+        </profile>
+    </profiles>
 </project>

topic/src/main/java/tech/ydb/topic/settings/ReaderSettings.java

@@ -12,7 +12,6 @@
 import tech.ydb.common.retry.RetryConfig;
 import tech.ydb.common.retry.RetryPolicy;
 import tech.ydb.core.Status;
-import tech.ydb.core.StatusCode;
 import tech.ydb.topic.impl.GrpcStreamRetrier;
 
 /**
@@ -143,15 +142,15 @@ public Builder setErrorsHandler(BiConsumer<Status, Throwable> handler) {
             final RetryConfig currentConfig = retryConfig;
             retryConfig = new RetryConfig() {
                 @Override
-                public RetryPolicy isStatusRetryable(StatusCode code) {
-                    handler.accept(Status.of(code), null);
-                    return currentConfig.isStatusRetryable(code);
+                public RetryPolicy getStatusRetryPolicy(Status status) {
+                    handler.accept(status, null);
+                    return currentConfig.getStatusRetryPolicy(status);
                 }
 
                 @Override
-                public RetryPolicy isThrowableRetryable(Throwable th) {
+                public RetryPolicy getThrowableRetryPolicy(Throwable th) {
                     handler.accept(null, th);
-                    return currentConfig.isThrowableRetryable(th);
+                    return currentConfig.getThrowableRetryPolicy(th);
                 }
             };
             return this;

topic/src/main/java/tech/ydb/topic/settings/WriterSettings.java

@@ -5,7 +5,6 @@
 import tech.ydb.common.retry.RetryConfig;
 import tech.ydb.common.retry.RetryPolicy;
 import tech.ydb.core.Status;
-import tech.ydb.core.StatusCode;
 import tech.ydb.topic.description.Codec;
 import tech.ydb.topic.impl.GrpcStreamRetrier;
 
@@ -187,15 +186,15 @@ public Builder setErrorsHandler(BiConsumer<Status, Throwable> handler) {
             final RetryConfig currentConfig = retryConfig;
             retryConfig = new RetryConfig() {
                 @Override
-                public RetryPolicy isStatusRetryable(StatusCode code) {
-                    handler.accept(Status.of(code), null);
-                    return currentConfig.isStatusRetryable(code);
+                public RetryPolicy getStatusRetryPolicy(Status status) {
+                    handler.accept(status, null);
+                    return currentConfig.getStatusRetryPolicy(status);
                 }
 
                 @Override
-                public RetryPolicy isThrowableRetryable(Throwable th) {
+                public RetryPolicy getThrowableRetryPolicy(Throwable th) {
                     handler.accept(null, th);
-                    return currentConfig.isThrowableRetryable(th);
+                    return currentConfig.getThrowableRetryPolicy(th);
                 }
             };
             return this;