Skip to content

Commit 04719ac

Browse files
author
awstools
committed
feat(client-kafkaconnect): Support dual-stack network connectivity for connectors via NetworkType field.
1 parent 9833262 commit 04719ac

25 files changed

+322
-427
lines changed

‎clients/client-kafkaconnect/src/commands/CreateConnectorCommand.ts‎

Lines changed: 8 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -96,6 +96,7 @@ export interface CreateConnectorCommandOutput extends CreateConnectorResponse, _
9696
* },
9797
* },
9898
* },
99+
* networkType: "STRING_VALUE",
99100
* plugins: [ // __listOfPlugin // required
100101
* { // Plugin
101102
* customPlugin: { // CustomPlugin
@@ -130,35 +131,28 @@ export interface CreateConnectorCommandOutput extends CreateConnectorResponse, _
130131
* @see {@link KafkaConnectClientResolvedConfig | config} for KafkaConnectClient's `config` shape.
131132
*
132133
* @throws {@link BadRequestException} (client fault)
133-
* <p>HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then
134-
* retry it.</p>
134+
* <p>HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then retry it.</p>
135135
*
136136
* @throws {@link ConflictException} (client fault)
137-
* <p>HTTP Status Code 409: Conflict. A resource with this name already exists. Retry your
138-
* request with another name.</p>
137+
* <p>HTTP Status Code 409: Conflict. A resource with this name already exists. Retry your request with another name.</p>
139138
*
140139
* @throws {@link ForbiddenException} (client fault)
141-
* <p>HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your
142-
* request.</p>
140+
* <p>HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your request.</p>
143141
*
144142
* @throws {@link InternalServerErrorException} (server fault)
145-
* <p>HTTP Status Code 500: Unexpected internal server error. Retrying your request might
146-
* resolve the issue.</p>
143+
* <p>HTTP Status Code 500: Unexpected internal server error. Retrying your request might resolve the issue.</p>
147144
*
148145
* @throws {@link NotFoundException} (client fault)
149-
* <p>HTTP Status Code 404: Resource not found due to incorrect input. Correct your request
150-
* and then retry it.</p>
146+
* <p>HTTP Status Code 404: Resource not found due to incorrect input. Correct your request and then retry it.</p>
151147
*
152148
* @throws {@link ServiceUnavailableException} (server fault)
153-
* <p>HTTP Status Code 503: Service Unavailable. Retrying your request in some time might
154-
* resolve the issue.</p>
149+
* <p>HTTP Status Code 503: Service Unavailable. Retrying your request in some time might resolve the issue.</p>
155150
*
156151
* @throws {@link TooManyRequestsException} (client fault)
157152
* <p>HTTP Status Code 429: Limit exceeded. Resource limit reached.</p>
158153
*
159154
* @throws {@link UnauthorizedException} (client fault)
160-
* <p>HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be
161-
* validated.</p>
155+
* <p>HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.</p>
162156
*
163157
* @throws {@link KafkaConnectServiceException}
164158
* <p>Base exception class for all service exceptions from KafkaConnect service.</p>

‎clients/client-kafkaconnect/src/commands/CreateCustomPluginCommand.ts‎

Lines changed: 7 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -69,35 +69,28 @@ export interface CreateCustomPluginCommandOutput extends CreateCustomPluginRespo
6969
* @see {@link KafkaConnectClientResolvedConfig | config} for KafkaConnectClient's `config` shape.
7070
*
7171
* @throws {@link BadRequestException} (client fault)
72-
* <p>HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then
73-
* retry it.</p>
72+
* <p>HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then retry it.</p>
7473
*
7574
* @throws {@link ConflictException} (client fault)
76-
* <p>HTTP Status Code 409: Conflict. A resource with this name already exists. Retry your
77-
* request with another name.</p>
75+
* <p>HTTP Status Code 409: Conflict. A resource with this name already exists. Retry your request with another name.</p>
7876
*
7977
* @throws {@link ForbiddenException} (client fault)
80-
* <p>HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your
81-
* request.</p>
78+
* <p>HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your request.</p>
8279
*
8380
* @throws {@link InternalServerErrorException} (server fault)
84-
* <p>HTTP Status Code 500: Unexpected internal server error. Retrying your request might
85-
* resolve the issue.</p>
81+
* <p>HTTP Status Code 500: Unexpected internal server error. Retrying your request might resolve the issue.</p>
8682
*
8783
* @throws {@link NotFoundException} (client fault)
88-
* <p>HTTP Status Code 404: Resource not found due to incorrect input. Correct your request
89-
* and then retry it.</p>
84+
* <p>HTTP Status Code 404: Resource not found due to incorrect input. Correct your request and then retry it.</p>
9085
*
9186
* @throws {@link ServiceUnavailableException} (server fault)
92-
* <p>HTTP Status Code 503: Service Unavailable. Retrying your request in some time might
93-
* resolve the issue.</p>
87+
* <p>HTTP Status Code 503: Service Unavailable. Retrying your request in some time might resolve the issue.</p>
9488
*
9589
* @throws {@link TooManyRequestsException} (client fault)
9690
* <p>HTTP Status Code 429: Limit exceeded. Resource limit reached.</p>
9791
*
9892
* @throws {@link UnauthorizedException} (client fault)
99-
* <p>HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be
100-
* validated.</p>
93+
* <p>HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.</p>
10194
*
10295
* @throws {@link KafkaConnectServiceException}
10396
* <p>Base exception class for all service exceptions from KafkaConnect service.</p>

‎clients/client-kafkaconnect/src/commands/CreateWorkerConfigurationCommand.ts‎

Lines changed: 7 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -67,35 +67,28 @@ export interface CreateWorkerConfigurationCommandOutput extends CreateWorkerConf
6767
* @see {@link KafkaConnectClientResolvedConfig | config} for KafkaConnectClient's `config` shape.
6868
*
6969
* @throws {@link BadRequestException} (client fault)
70-
* <p>HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then
71-
* retry it.</p>
70+
* <p>HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then retry it.</p>
7271
*
7372
* @throws {@link ConflictException} (client fault)
74-
* <p>HTTP Status Code 409: Conflict. A resource with this name already exists. Retry your
75-
* request with another name.</p>
73+
* <p>HTTP Status Code 409: Conflict. A resource with this name already exists. Retry your request with another name.</p>
7674
*
7775
* @throws {@link ForbiddenException} (client fault)
78-
* <p>HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your
79-
* request.</p>
76+
* <p>HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your request.</p>
8077
*
8178
* @throws {@link InternalServerErrorException} (server fault)
82-
* <p>HTTP Status Code 500: Unexpected internal server error. Retrying your request might
83-
* resolve the issue.</p>
79+
* <p>HTTP Status Code 500: Unexpected internal server error. Retrying your request might resolve the issue.</p>
8480
*
8581
* @throws {@link NotFoundException} (client fault)
86-
* <p>HTTP Status Code 404: Resource not found due to incorrect input. Correct your request
87-
* and then retry it.</p>
82+
* <p>HTTP Status Code 404: Resource not found due to incorrect input. Correct your request and then retry it.</p>
8883
*
8984
* @throws {@link ServiceUnavailableException} (server fault)
90-
* <p>HTTP Status Code 503: Service Unavailable. Retrying your request in some time might
91-
* resolve the issue.</p>
85+
* <p>HTTP Status Code 503: Service Unavailable. Retrying your request in some time might resolve the issue.</p>
9286
*
9387
* @throws {@link TooManyRequestsException} (client fault)
9488
* <p>HTTP Status Code 429: Limit exceeded. Resource limit reached.</p>
9589
*
9690
* @throws {@link UnauthorizedException} (client fault)
97-
* <p>HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be
98-
* validated.</p>
91+
* <p>HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.</p>
9992
*
10093
* @throws {@link KafkaConnectServiceException}
10194
* <p>Base exception class for all service exceptions from KafkaConnect service.</p>

‎clients/client-kafkaconnect/src/commands/DeleteConnectorCommand.ts‎

Lines changed: 6 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -56,31 +56,25 @@ export interface DeleteConnectorCommandOutput extends DeleteConnectorResponse, _
5656
* @see {@link KafkaConnectClientResolvedConfig | config} for KafkaConnectClient's `config` shape.
5757
*
5858
* @throws {@link BadRequestException} (client fault)
59-
* <p>HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then
60-
* retry it.</p>
59+
* <p>HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then retry it.</p>
6160
*
6261
* @throws {@link ForbiddenException} (client fault)
63-
* <p>HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your
64-
* request.</p>
62+
* <p>HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your request.</p>
6563
*
6664
* @throws {@link InternalServerErrorException} (server fault)
67-
* <p>HTTP Status Code 500: Unexpected internal server error. Retrying your request might
68-
* resolve the issue.</p>
65+
* <p>HTTP Status Code 500: Unexpected internal server error. Retrying your request might resolve the issue.</p>
6966
*
7067
* @throws {@link NotFoundException} (client fault)
71-
* <p>HTTP Status Code 404: Resource not found due to incorrect input. Correct your request
72-
* and then retry it.</p>
68+
* <p>HTTP Status Code 404: Resource not found due to incorrect input. Correct your request and then retry it.</p>
7369
*
7470
* @throws {@link ServiceUnavailableException} (server fault)
75-
* <p>HTTP Status Code 503: Service Unavailable. Retrying your request in some time might
76-
* resolve the issue.</p>
71+
* <p>HTTP Status Code 503: Service Unavailable. Retrying your request in some time might resolve the issue.</p>
7772
*
7873
* @throws {@link TooManyRequestsException} (client fault)
7974
* <p>HTTP Status Code 429: Limit exceeded. Resource limit reached.</p>
8075
*
8176
* @throws {@link UnauthorizedException} (client fault)
82-
* <p>HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be
83-
* validated.</p>
77+
* <p>HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.</p>
8478
*
8579
* @throws {@link KafkaConnectServiceException}
8680
* <p>Base exception class for all service exceptions from KafkaConnect service.</p>

‎clients/client-kafkaconnect/src/commands/DeleteCustomPluginCommand.ts‎

Lines changed: 6 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -55,31 +55,25 @@ export interface DeleteCustomPluginCommandOutput extends DeleteCustomPluginRespo
5555
* @see {@link KafkaConnectClientResolvedConfig | config} for KafkaConnectClient's `config` shape.
5656
*
5757
* @throws {@link BadRequestException} (client fault)
58-
* <p>HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then
59-
* retry it.</p>
58+
* <p>HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then retry it.</p>
6059
*
6160
* @throws {@link ForbiddenException} (client fault)
62-
* <p>HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your
63-
* request.</p>
61+
* <p>HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your request.</p>
6462
*
6563
* @throws {@link InternalServerErrorException} (server fault)
66-
* <p>HTTP Status Code 500: Unexpected internal server error. Retrying your request might
67-
* resolve the issue.</p>
64+
* <p>HTTP Status Code 500: Unexpected internal server error. Retrying your request might resolve the issue.</p>
6865
*
6966
* @throws {@link NotFoundException} (client fault)
70-
* <p>HTTP Status Code 404: Resource not found due to incorrect input. Correct your request
71-
* and then retry it.</p>
67+
* <p>HTTP Status Code 404: Resource not found due to incorrect input. Correct your request and then retry it.</p>
7268
*
7369
* @throws {@link ServiceUnavailableException} (server fault)
74-
* <p>HTTP Status Code 503: Service Unavailable. Retrying your request in some time might
75-
* resolve the issue.</p>
70+
* <p>HTTP Status Code 503: Service Unavailable. Retrying your request in some time might resolve the issue.</p>
7671
*
7772
* @throws {@link TooManyRequestsException} (client fault)
7873
* <p>HTTP Status Code 429: Limit exceeded. Resource limit reached.</p>
7974
*
8075
* @throws {@link UnauthorizedException} (client fault)
81-
* <p>HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be
82-
* validated.</p>
76+
* <p>HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.</p>
8377
*
8478
* @throws {@link KafkaConnectServiceException}
8579
* <p>Base exception class for all service exceptions from KafkaConnect service.</p>

‎clients/client-kafkaconnect/src/commands/DeleteWorkerConfigurationCommand.ts‎

Lines changed: 6 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -55,31 +55,25 @@ export interface DeleteWorkerConfigurationCommandOutput extends DeleteWorkerConf
5555
* @see {@link KafkaConnectClientResolvedConfig | config} for KafkaConnectClient's `config` shape.
5656
*
5757
* @throws {@link BadRequestException} (client fault)
58-
* <p>HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then
59-
* retry it.</p>
58+
* <p>HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then retry it.</p>
6059
*
6160
* @throws {@link ForbiddenException} (client fault)
62-
* <p>HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your
63-
* request.</p>
61+
* <p>HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your request.</p>
6462
*
6563
* @throws {@link InternalServerErrorException} (server fault)
66-
* <p>HTTP Status Code 500: Unexpected internal server error. Retrying your request might
67-
* resolve the issue.</p>
64+
* <p>HTTP Status Code 500: Unexpected internal server error. Retrying your request might resolve the issue.</p>
6865
*
6966
* @throws {@link NotFoundException} (client fault)
70-
* <p>HTTP Status Code 404: Resource not found due to incorrect input. Correct your request
71-
* and then retry it.</p>
67+
* <p>HTTP Status Code 404: Resource not found due to incorrect input. Correct your request and then retry it.</p>
7268
*
7369
* @throws {@link ServiceUnavailableException} (server fault)
74-
* <p>HTTP Status Code 503: Service Unavailable. Retrying your request in some time might
75-
* resolve the issue.</p>
70+
* <p>HTTP Status Code 503: Service Unavailable. Retrying your request in some time might resolve the issue.</p>
7671
*
7772
* @throws {@link TooManyRequestsException} (client fault)
7873
* <p>HTTP Status Code 429: Limit exceeded. Resource limit reached.</p>
7974
*
8075
* @throws {@link UnauthorizedException} (client fault)
81-
* <p>HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be
82-
* validated.</p>
76+
* <p>HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.</p>
8377
*
8478
* @throws {@link KafkaConnectServiceException}
8579
* <p>Base exception class for all service exceptions from KafkaConnect service.</p>

‎clients/client-kafkaconnect/src/commands/DescribeConnectorCommand.ts‎

Lines changed: 7 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -105,6 +105,7 @@ export interface DescribeConnectorCommandOutput extends DescribeConnectorRespons
105105
* // },
106106
* // },
107107
* // },
108+
* // networkType: "STRING_VALUE",
108109
* // plugins: [ // __listOfPluginDescription
109110
* // { // PluginDescription
110111
* // customPlugin: { // CustomPluginDescription
@@ -133,31 +134,25 @@ export interface DescribeConnectorCommandOutput extends DescribeConnectorRespons
133134
* @see {@link KafkaConnectClientResolvedConfig | config} for KafkaConnectClient's `config` shape.
134135
*
135136
* @throws {@link BadRequestException} (client fault)
136-
* <p>HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then
137-
* retry it.</p>
137+
* <p>HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then retry it.</p>
138138
*
139139
* @throws {@link ForbiddenException} (client fault)
140-
* <p>HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your
141-
* request.</p>
140+
* <p>HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your request.</p>
142141
*
143142
* @throws {@link InternalServerErrorException} (server fault)
144-
* <p>HTTP Status Code 500: Unexpected internal server error. Retrying your request might
145-
* resolve the issue.</p>
143+
* <p>HTTP Status Code 500: Unexpected internal server error. Retrying your request might resolve the issue.</p>
146144
*
147145
* @throws {@link NotFoundException} (client fault)
148-
* <p>HTTP Status Code 404: Resource not found due to incorrect input. Correct your request
149-
* and then retry it.</p>
146+
* <p>HTTP Status Code 404: Resource not found due to incorrect input. Correct your request and then retry it.</p>
150147
*
151148
* @throws {@link ServiceUnavailableException} (server fault)
152-
* <p>HTTP Status Code 503: Service Unavailable. Retrying your request in some time might
153-
* resolve the issue.</p>
149+
* <p>HTTP Status Code 503: Service Unavailable. Retrying your request in some time might resolve the issue.</p>
154150
*
155151
* @throws {@link TooManyRequestsException} (client fault)
156152
* <p>HTTP Status Code 429: Limit exceeded. Resource limit reached.</p>
157153
*
158154
* @throws {@link UnauthorizedException} (client fault)
159-
* <p>HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be
160-
* validated.</p>
155+
* <p>HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.</p>
161156
*
162157
* @throws {@link KafkaConnectServiceException}
163158
* <p>Base exception class for all service exceptions from KafkaConnect service.</p>

‎clients/client-kafkaconnect/src/commands/DescribeConnectorOperationCommand.ts‎

Lines changed: 6 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -113,31 +113,25 @@ export interface DescribeConnectorOperationCommandOutput extends DescribeConnect
113113
* @see {@link KafkaConnectClientResolvedConfig | config} for KafkaConnectClient's `config` shape.
114114
*
115115
* @throws {@link BadRequestException} (client fault)
116-
* <p>HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then
117-
* retry it.</p>
116+
* <p>HTTP Status Code 400: Bad request due to incorrect input. Correct your request and then retry it.</p>
118117
*
119118
* @throws {@link ForbiddenException} (client fault)
120-
* <p>HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your
121-
* request.</p>
119+
* <p>HTTP Status Code 403: Access forbidden. Correct your credentials and then retry your request.</p>
122120
*
123121
* @throws {@link InternalServerErrorException} (server fault)
124-
* <p>HTTP Status Code 500: Unexpected internal server error. Retrying your request might
125-
* resolve the issue.</p>
122+
* <p>HTTP Status Code 500: Unexpected internal server error. Retrying your request might resolve the issue.</p>
126123
*
127124
* @throws {@link NotFoundException} (client fault)
128-
* <p>HTTP Status Code 404: Resource not found due to incorrect input. Correct your request
129-
* and then retry it.</p>
125+
* <p>HTTP Status Code 404: Resource not found due to incorrect input. Correct your request and then retry it.</p>
130126
*
131127
* @throws {@link ServiceUnavailableException} (server fault)
132-
* <p>HTTP Status Code 503: Service Unavailable. Retrying your request in some time might
133-
* resolve the issue.</p>
128+
* <p>HTTP Status Code 503: Service Unavailable. Retrying your request in some time might resolve the issue.</p>
134129
*
135130
* @throws {@link TooManyRequestsException} (client fault)
136131
* <p>HTTP Status Code 429: Limit exceeded. Resource limit reached.</p>
137132
*
138133
* @throws {@link UnauthorizedException} (client fault)
139-
* <p>HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be
140-
* validated.</p>
134+
* <p>HTTP Status Code 401: Unauthorized request. The provided credentials couldn't be validated.</p>
141135
*
142136
* @throws {@link KafkaConnectServiceException}
143137
* <p>Base exception class for all service exceptions from KafkaConnect service.</p>

0 commit comments

Comments
 (0)