Skip to content

Commit c5e1edb

Browse files
committed
fix stopConnector override with new retry mechanism
1 parent c954409 commit c5e1edb

File tree

1 file changed

+8
-3
lines changed

1 file changed

+8
-3
lines changed

api/src/main/java/io/kafbat/ui/client/RetryingKafkaConnectClient.java

Lines changed: 8 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -233,14 +233,19 @@ public Mono<Void> pauseConnector(String connectorName) throws WebClientResponseE
233233
return withRetryOnConflictOrRebalance(super.pauseConnector(connectorName));
234234
}
235235

236+
@Override
237+
public Mono<ResponseEntity<Void>> pauseConnectorWithHttpInfo(String connectorName) throws WebClientResponseException {
238+
return withRetryOnConflictOrRebalance(super.pauseConnectorWithHttpInfo(connectorName));
239+
}
240+
236241
@Override
237242
public Mono<Void> stopConnector(String connectorName) throws WebClientResponseException {
238-
return withRetryOnConflict(super.stopConnector(connectorName));
243+
return withRetryOnConflictOrRebalance(super.stopConnector(connectorName));
239244
}
240245

241246
@Override
242-
public Mono<ResponseEntity<Void>> pauseConnectorWithHttpInfo(String connectorName) throws WebClientResponseException {
243-
return withRetryOnConflictOrRebalance(super.pauseConnectorWithHttpInfo(connectorName));
247+
public Mono<ResponseEntity<Void>> stopConnectorWithHttpInfo(String connectorName) throws WebClientResponseException {
248+
return withRetryOnConflictOrRebalance(super.stopConnectorWithHttpInfo(connectorName));
244249
}
245250

246251
@Override

0 commit comments

Comments
 (0)