File tree Expand file tree Collapse file tree 1 file changed +8
-3
lines changed
api/src/main/java/io/kafbat/ui/client Expand file tree Collapse file tree 1 file changed +8
-3
lines changed Original file line number Diff line number Diff 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
You can’t perform that action at this time.
0 commit comments