Add dropdown options to pause and stop connectors

Author: Dugong42

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

@@ -190,6 +190,11 @@ public Mono<Void> pauseConnector(String connectorName) throws WebClientResponseE
  return withRetryOnConflict(super.pauseConnector(connectorName));
  }
 
+ @Override
+ public Mono<Void> stopConnector(String connectorName) throws WebClientResponseException {
+ return withRetryOnConflict(super.stopConnector(connectorName));
+ }
+
  @Override
  public Mono<ResponseEntity<Void>> pauseConnectorWithHttpInfo(String connectorName) throws WebClientResponseException {
  return withRetryOnConflict(super.pauseConnectorWithHttpInfo(connectorName));

api/src/main/java/io/kafbat/ui/service/KafkaConnectService.java

@@ -229,6 +229,8 @@ public Mono<Void> updateConnectorState(KafkaCluster cluster, String connectName,
  t -> t.getStatus().getState() == ConnectorTaskStatusDTO.FAILED);
  case PAUSE:
  return client.pauseConnector(connectorName);
+ case STOP:
+ return client.stopConnector(connectorName);
  case RESUME:
  return client.resumeConnector(connectorName);
  default:

contract/src/main/resources/swagger/kafbat-ui-api.yaml

@@ -1542,7 +1542,7 @@ paths:
  post:
  tags:
  - Kafka Connect
- summary: update connector state (restart, pause or resume)
+ summary: update connector state (restart, pause, stop or resume)
  operationId: updateConnectorState
  parameters:
  - name: clusterName
@@ -3482,6 +3482,7 @@ components:
  - RESTART_FAILED_TASKS
  - PAUSE
  - RESUME
+ - STOP
 
  TaskAction:
  type: string
@@ -3867,7 +3868,16 @@ components:
 
  KafkaAcl:
  type: object
- required: [resourceType, resourceName, namePatternType, principal, host, operation, permission]
+ required:
+ [
+ resourceType,
+ resourceName,
+ namePatternType,
+ principal,
+ host,
+ operation,
+ permission,
+ ]
  properties:
  resourceType:
  $ref: '#/components/schemas/KafkaAclResourceType'

contract/src/main/resources/swagger/kafka-connect-api.yaml

@@ -230,6 +230,22 @@ paths:
  202:
  description: Accepted
 
+ /connectors/{connectorName}/stop:
+ put:
+ tags:
+ - KafkaConnectClient
+ summary: stop the connector
+ operationId: stopConnector
+ parameters:
+ - name: connectorName
+ in: path
+ required: true
+ schema:
+ type: string
+ responses:
+ 204:
+ description: No Content
+
  /connectors/{connectorName}/tasks:
  get:
  tags:

frontend/src/components/Connect/Details/Actions/Actions.tsx

@@ -59,6 +59,8 @@ const Actions: React.FC = () => {
  stateMutation.mutateAsync(ConnectorAction.RESTART_FAILED_TASKS);
  const pauseConnectorHandler = () =>
  stateMutation.mutateAsync(ConnectorAction.PAUSE);
+ const stopConnectorHandler = () =>
+ stateMutation.mutateAsync(ConnectorAction.STOP);
  const resumeConnectorHandler = () =>
  stateMutation.mutateAsync(ConnectorAction.RESUME);
  return (
@@ -84,7 +86,20 @@ const Actions: React.FC = () => {
  Pause
  </ActionDropdownItem>
  )}
- {connector?.status.state === ConnectorState.PAUSED && (
+ {connector?.status.state === ConnectorState.RUNNING && (
+ <ActionDropdownItem
+ onClick={stopConnectorHandler}
+ disabled={isMutating}
+ permission={{
+ resource: ResourceType.CONNECT,
+ action: Action.EDIT,
+ value: routerProps.connectName,
+ }}
+ >
+ Stop Connector
+ </ActionDropdownItem>
+ )}
+ {(connector?.status.state === ConnectorState.PAUSED || connector?.status.state === ConnectorState.STOPPED) && (
  <ActionDropdownItem
  onClick={resumeConnectorHandler}
  disabled={isMutating}

frontend/src/components/Connect/List/ActionsCell.tsx

@@ -58,9 +58,15 @@ const ActionsCell: React.FC<CellContext<FullConnectorInfo, unknown>> = ({
  const restartFailedTasksHandler = () =>
  stateMutation.mutateAsync(ConnectorAction.RESTART_FAILED_TASKS);
 
+ const pauseConnectorHandler = () =>
+ stateMutation.mutateAsync(ConnectorAction.PAUSE);
+
+ const stopConnectorHandler = () =>
+ stateMutation.mutateAsync(ConnectorAction.STOP);
+
  return (
  <Dropdown>
- {status.state === ConnectorState.PAUSED && (
+ {(status.state === ConnectorState.PAUSED || status.state === ConnectorState.STOPPED) && (
  <ActionDropdownItem
  onClick={resumeConnectorHandler}
  disabled={isMutating}
@@ -73,6 +79,32 @@ const ActionsCell: React.FC<CellContext<FullConnectorInfo, unknown>> = ({
  Resume
  </ActionDropdownItem>
  )}
+ {status.state === ConnectorState.RUNNING && (
+ <ActionDropdownItem
+ onClick={pauseConnectorHandler}
+ disabled={isMutating}
+ permission={{
+ resource: ResourceType.CONNECT,
+ action: Action.EDIT,
+ value: connect,
+ }}
+ >
+ Pause Connector
+ </ActionDropdownItem>
+ )}
+ {status.state === ConnectorState.RUNNING && (
+ <ActionDropdownItem
+ onClick={stopConnectorHandler}
+ disabled={isMutating}
+ permission={{
+ resource: ResourceType.CONNECT,
+ action: Action.EDIT,
+ value: connect,
+ }}
+ >
+ Stop Connector
+ </ActionDropdownItem>
+ )}
  <ActionDropdownItem
  onClick={restartConnectorHandler}
  disabled={isMutating}