Skip to content

Commit bb03a61

Browse files
committed
add KafkaConnectClient::restartConnector(final PostConnectorRestart connectorRestartRequest)
1 parent 6f33b71 commit bb03a61

File tree

3 files changed

+21
-4
lines changed

3 files changed

+21
-4
lines changed

CHANGELOG.md

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -3,10 +3,9 @@ The format is based on [Keep a Changelog](http://keepachangelog.com/)
33
and this project adheres to [Semantic Versioning](http://semver.org/).
44

55
## 4.0.2 (10/09/2022)
6+
- Adds `KafkaConnectClient::restartConnector(final PostConnectorRestart connectorRestartRequest)` [Issue-78](https://github.com/SourceLabOrg/kafka-connect-client/issues/78).
67
- Fix Javadoc on KafkaConnectClient::deleteConnector(). [issue-76](https://github.com/SourceLabOrg/kafka-connect-client/issues/76).
7-
- Add Constructors to various internal classes:
8-
- [ConnectServerVersion](https://github.com/SourceLabOrg/kafka-connect-client/blob/master/src/main/java/org/sourcelab/kafka/connect/apiclient/request/dto/ConnectServerVersion.java#L23)
9-
- [Task](https://github.com/SourceLabOrg/kafka-connect-client/blob/master/src/main/java/org/sourcelab/kafka/connect/apiclient/request/dto/Task.java#L25)
8+
- Add Constructors to various internal "DTO" classes, this allows for easier testing/mocking of responses.
109
- com.fasterxml.jackson.core from 2.13.3 -> 2.13.4
1110
-
1211
## 4.0.1 (08/20/2022)

src/main/java/org/sourcelab/kafka/connect/apiclient/KafkaConnectClient.java

Lines changed: 13 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -258,7 +258,19 @@ public ConnectorDefinition updateConnectorConfig(final String connectorName, fin
258258
* @return Boolean true if success.
259259
*/
260260
public Boolean restartConnector(final String connectorName) {
261-
return submitRequest(new PostConnectorRestart(connectorName));
261+
return restartConnector(new PostConnectorRestart(connectorName));
262+
}
263+
264+
/**
265+
* Restart a connector.
266+
* https://docs.confluent.io/current/connect/references/restapi.html#post--connectors-(string-name)-restart
267+
*
268+
* @param connectorRestartRequest Defines the connector restart request.
269+
* @return Boolean true if success.
270+
*/
271+
public Boolean restartConnector(final PostConnectorRestart connectorRestartRequest)
272+
{
273+
return submitRequest(connectorRestartRequest);
262274
}
263275

264276
/**

src/main/java/org/sourcelab/kafka/connect/apiclient/request/post/PostConnectorRestart.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -30,8 +30,14 @@
3030
* Defines a request to restart a connector.
3131
*/
3232
public final class PostConnectorRestart implements PostRequest<Boolean> {
33+
/**
34+
* Defines the name of the connector to restart.
35+
*/
3336
private final String connectorName;
3437

38+
/**
39+
* Additional options to pass with the request.
40+
*/
3541
private Map<String, Boolean> options = new HashMap<>();
3642

3743
/**

0 commit comments

Comments
 (0)