File tree Expand file tree Collapse file tree 5 files changed +46
-3
lines changed
src/main/java/org/sourcelab/kafka/connect/apiclient Expand file tree Collapse file tree 5 files changed +46
-3
lines changed Original file line number Diff line number Diff line change 22The format is based on [ Keep a Changelog] ( http://keepachangelog.com/ )
33and this project adheres to [ Semantic Versioning] ( http://semver.org/ ) .
44
5+ ## 4.0.2 (10/09/2022)
6+ - 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 )
10+
511## 4.0.1 (08/20/2022)
612#### Internal Dependency Updates
713- com.fasterxml.jackson.core from 2.13.0 -> 2.13.3
Original file line number Diff line number Diff line change 66
77 <groupId >org.sourcelab</groupId >
88 <artifactId >kafka-connect-client</artifactId >
9- <version >4.0.1 </version >
9+ <version >4.0.2 </version >
1010 <packaging >jar</packaging >
1111
1212 <!-- Require Maven 3.3.9 -->
Original file line number Diff line number Diff line change @@ -284,8 +284,8 @@ public Boolean resumeConnector(final String connectorName) {
284284 }
285285
286286 /**
287- * Resume a connector.
288- * https://docs.confluent.io/current/connect/references/restapi.html#put --connectors-(string-name)-resume
287+ * Delete a connector.
288+ * https://docs.confluent.io/platform/ current/connect/references/restapi.html#delete --connectors-(string-name)-
289289 *
290290 * @param connectorName Name of connector to resume.
291291 * @return Boolean true if success.
Original file line number Diff line number Diff line change @@ -25,6 +25,22 @@ public class ConnectServerVersion {
2525 private String commit ;
2626 private String kafkaClusterId ;
2727
28+ /**
29+ * Constructor.
30+ */
31+ public ConnectServerVersion ()
32+ {
33+ }
34+
35+ /**
36+ * Constructor.
37+ */
38+ public ConnectServerVersion (final String version , final String commit , final String kafkaClusterId ) {
39+ this .version = version ;
40+ this .commit = commit ;
41+ this .kafkaClusterId = kafkaClusterId ;
42+ }
43+
2844 /**
2945 * Version of running Kafka-Connect server.
3046 * @return Version of running Kafka-Connect server.
Original file line number Diff line number Diff line change @@ -26,6 +26,16 @@ public final class Task {
2626 private TaskId id ;
2727 private Map <String , String > config ;
2828
29+ public Task () {
30+
31+ }
32+
33+ public Task (final TaskId id , Map <String , String > config )
34+ {
35+ this .id = id ;
36+ this .config = config ;
37+ }
38+
2939 public TaskId getId () {
3040 return id ;
3141 }
@@ -49,6 +59,16 @@ public static class TaskId {
4959 private String connector ;
5060 private int task ;
5161
62+ public TaskId ()
63+ {
64+
65+ }
66+
67+ public TaskId (final String connector , final int task ) {
68+ this .connector = connector ;
69+ this .task = task ;
70+ }
71+
5272 public String getConnector () {
5373 return connector ;
5474 }
@@ -65,4 +85,5 @@ public String toString() {
6585 + '}' ;
6686 }
6787 }
88+
6889}
You can’t perform that action at this time.
0 commit comments