use the proper return type for the client interface

kafbat · Jan 3, 2025 · c954409 · c954409
1 parent 77b5a70
commit c954409
Showing 1 changed file with 12 additions and 6 deletions.
diff --git a/api/src/main/java/io/kafbat/ui/client/RetryingKafkaConnectClient.java b/api/src/main/java/io/kafbat/ui/client/RetryingKafkaConnectClient.java
@@ -267,20 +267,26 @@ public Mono<ResponseEntity<Void>> restartConnectorTaskWithHttpInfo(String connec
   }
 
   @Override
-  public Mono<Void> resumeConnector(String connectorName) throws WebClientResponseException {
-    return withRetryOnRebalance(super.resumeConnector(connectorName));
+  public Mono<Void> resetConnectorOffsets(String connectorName)
+      throws WebClientResponseException {
+    return withRetryOnConflictOrRebalance(super.resetConnectorOffsets(connectorName));
   }
 
   @Override
-  public Mono<ResponseEntity<Void>> resumeConnectorWithHttpInfo(String connectorName)
+  public Mono<ResponseEntity<Void>> resetConnectorOffsetsWithHttpInfo(String connectorName)
       throws WebClientResponseException {
-    return withRetryOnConflictOrRebalance(super.resumeConnectorWithHttpInfo(connectorName));
+    return withRetryOnConflictOrRebalance(super.resetConnectorOffsetsWithHttpInfo(connectorName));
+  }
+
+  @Override
+  public Mono<Void> resumeConnector(String connectorName) throws WebClientResponseException {
+    return withRetryOnRebalance(super.resumeConnector(connectorName));
   }
 
   @Override
-  public Mono<ResponseEntity<Void>> resetConnectorOffsets(String connectorName)
+  public Mono<ResponseEntity<Void>> resumeConnectorWithHttpInfo(String connectorName)
       throws WebClientResponseException {
-    return withRetryOnConflictOrRebalance(super.resetConnectorOffsets(connectorName));
+    return withRetryOnConflictOrRebalance(super.resumeConnectorWithHttpInfo(connectorName));
   }
 
   @Override