Skip to content

Commit db53ab1

Browse files
author
awstools
committed
feat(client-kafka): AWS Managed Streaming for Kafka is launching MSK Replicator, a new feature that enables customers to reliably replicate data across Amazon MSK clusters in same or different AWS regions. You can now use SDK to create, list, describe, delete, update, and manage tags of MSK Replicators.
1 parent 9a3a3f6 commit db53ab1

File tree

15 files changed

+4157
-112
lines changed

15 files changed

+4157
-112
lines changed

clients/client-kafka/README.md

Lines changed: 40 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -242,6 +242,14 @@ CreateConfiguration
242242

243243
[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-kafka/classes/createconfigurationcommand.html) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-kafka/interfaces/createconfigurationcommandinput.html) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-kafka/interfaces/createconfigurationcommandoutput.html)
244244

245+
</details>
246+
<details>
247+
<summary>
248+
CreateReplicator
249+
</summary>
250+
251+
[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-kafka/classes/createreplicatorcommand.html) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-kafka/interfaces/createreplicatorcommandinput.html) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-kafka/interfaces/createreplicatorcommandoutput.html)
252+
245253
</details>
246254
<details>
247255
<summary>
@@ -274,6 +282,14 @@ DeleteConfiguration
274282

275283
[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-kafka/classes/deleteconfigurationcommand.html) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-kafka/interfaces/deleteconfigurationcommandinput.html) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-kafka/interfaces/deleteconfigurationcommandoutput.html)
276284

285+
</details>
286+
<details>
287+
<summary>
288+
DeleteReplicator
289+
</summary>
290+
291+
[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-kafka/classes/deletereplicatorcommand.html) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-kafka/interfaces/deletereplicatorcommandinput.html) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-kafka/interfaces/deletereplicatorcommandoutput.html)
292+
277293
</details>
278294
<details>
279295
<summary>
@@ -330,6 +346,14 @@ DescribeConfigurationRevision
330346

331347
[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-kafka/classes/describeconfigurationrevisioncommand.html) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-kafka/interfaces/describeconfigurationrevisioncommandinput.html) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-kafka/interfaces/describeconfigurationrevisioncommandoutput.html)
332348

349+
</details>
350+
<details>
351+
<summary>
352+
DescribeReplicator
353+
</summary>
354+
355+
[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-kafka/classes/describereplicatorcommand.html) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-kafka/interfaces/describereplicatorcommandinput.html) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-kafka/interfaces/describereplicatorcommandoutput.html)
356+
333357
</details>
334358
<details>
335359
<summary>
@@ -434,6 +458,14 @@ ListNodes
434458

435459
[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-kafka/classes/listnodescommand.html) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-kafka/interfaces/listnodescommandinput.html) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-kafka/interfaces/listnodescommandoutput.html)
436460

461+
</details>
462+
<details>
463+
<summary>
464+
ListReplicators
465+
</summary>
466+
467+
[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-kafka/classes/listreplicatorscommand.html) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-kafka/interfaces/listreplicatorscommandinput.html) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-kafka/interfaces/listreplicatorscommandoutput.html)
468+
437469
</details>
438470
<details>
439471
<summary>
@@ -562,6 +594,14 @@ UpdateMonitoring
562594

563595
[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-kafka/classes/updatemonitoringcommand.html) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-kafka/interfaces/updatemonitoringcommandinput.html) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-kafka/interfaces/updatemonitoringcommandoutput.html)
564596

597+
</details>
598+
<details>
599+
<summary>
600+
UpdateReplicationInfo
601+
</summary>
602+
603+
[Command API Reference](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-kafka/classes/updatereplicationinfocommand.html) / [Input](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-kafka/interfaces/updatereplicationinfocommandinput.html) / [Output](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/clients/client-kafka/interfaces/updatereplicationinfocommandoutput.html)
604+
565605
</details>
566606
<details>
567607
<summary>

clients/client-kafka/src/Kafka.ts

Lines changed: 112 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -27,6 +27,11 @@ import {
2727
CreateConfigurationCommandInput,
2828
CreateConfigurationCommandOutput,
2929
} from "./commands/CreateConfigurationCommand";
30+
import {
31+
CreateReplicatorCommand,
32+
CreateReplicatorCommandInput,
33+
CreateReplicatorCommandOutput,
34+
} from "./commands/CreateReplicatorCommand";
3035
import {
3136
CreateVpcConnectionCommand,
3237
CreateVpcConnectionCommandInput,
@@ -47,6 +52,11 @@ import {
4752
DeleteConfigurationCommandInput,
4853
DeleteConfigurationCommandOutput,
4954
} from "./commands/DeleteConfigurationCommand";
55+
import {
56+
DeleteReplicatorCommand,
57+
DeleteReplicatorCommandInput,
58+
DeleteReplicatorCommandOutput,
59+
} from "./commands/DeleteReplicatorCommand";
5060
import {
5161
DeleteVpcConnectionCommand,
5262
DeleteVpcConnectionCommandInput,
@@ -82,6 +92,11 @@ import {
8292
DescribeConfigurationRevisionCommandInput,
8393
DescribeConfigurationRevisionCommandOutput,
8494
} from "./commands/DescribeConfigurationRevisionCommand";
95+
import {
96+
DescribeReplicatorCommand,
97+
DescribeReplicatorCommandInput,
98+
DescribeReplicatorCommandOutput,
99+
} from "./commands/DescribeReplicatorCommand";
85100
import {
86101
DescribeVpcConnectionCommand,
87102
DescribeVpcConnectionCommandInput,
@@ -143,6 +158,11 @@ import {
143158
ListKafkaVersionsCommandOutput,
144159
} from "./commands/ListKafkaVersionsCommand";
145160
import { ListNodesCommand, ListNodesCommandInput, ListNodesCommandOutput } from "./commands/ListNodesCommand";
161+
import {
162+
ListReplicatorsCommand,
163+
ListReplicatorsCommandInput,
164+
ListReplicatorsCommandOutput,
165+
} from "./commands/ListReplicatorsCommand";
146166
import {
147167
ListScramSecretsCommand,
148168
ListScramSecretsCommandInput,
@@ -219,6 +239,11 @@ import {
219239
UpdateMonitoringCommandInput,
220240
UpdateMonitoringCommandOutput,
221241
} from "./commands/UpdateMonitoringCommand";
242+
import {
243+
UpdateReplicationInfoCommand,
244+
UpdateReplicationInfoCommandInput,
245+
UpdateReplicationInfoCommandOutput,
246+
} from "./commands/UpdateReplicationInfoCommand";
222247
import {
223248
UpdateSecurityCommand,
224249
UpdateSecurityCommandInput,
@@ -237,17 +262,20 @@ const commands = {
237262
CreateClusterCommand,
238263
CreateClusterV2Command,
239264
CreateConfigurationCommand,
265+
CreateReplicatorCommand,
240266
CreateVpcConnectionCommand,
241267
DeleteClusterCommand,
242268
DeleteClusterPolicyCommand,
243269
DeleteConfigurationCommand,
270+
DeleteReplicatorCommand,
244271
DeleteVpcConnectionCommand,
245272
DescribeClusterCommand,
246273
DescribeClusterOperationCommand,
247274
DescribeClusterOperationV2Command,
248275
DescribeClusterV2Command,
249276
DescribeConfigurationCommand,
250277
DescribeConfigurationRevisionCommand,
278+
DescribeReplicatorCommand,
251279
DescribeVpcConnectionCommand,
252280
GetBootstrapBrokersCommand,
253281
GetClusterPolicyCommand,
@@ -261,6 +289,7 @@ const commands = {
261289
ListConfigurationsCommand,
262290
ListKafkaVersionsCommand,
263291
ListNodesCommand,
292+
ListReplicatorsCommand,
264293
ListScramSecretsCommand,
265294
ListTagsForResourceCommand,
266295
ListVpcConnectionsCommand,
@@ -277,6 +306,7 @@ const commands = {
277306
UpdateConfigurationCommand,
278307
UpdateConnectivityCommand,
279308
UpdateMonitoringCommand,
309+
UpdateReplicationInfoCommand,
280310
UpdateSecurityCommand,
281311
UpdateStorageCommand,
282312
};
@@ -358,6 +388,23 @@ export interface Kafka {
358388
cb: (err: any, data?: CreateConfigurationCommandOutput) => void
359389
): void;
360390

391+
/**
392+
* @see {@link CreateReplicatorCommand}
393+
*/
394+
createReplicator(
395+
args: CreateReplicatorCommandInput,
396+
options?: __HttpHandlerOptions
397+
): Promise<CreateReplicatorCommandOutput>;
398+
createReplicator(
399+
args: CreateReplicatorCommandInput,
400+
cb: (err: any, data?: CreateReplicatorCommandOutput) => void
401+
): void;
402+
createReplicator(
403+
args: CreateReplicatorCommandInput,
404+
options: __HttpHandlerOptions,
405+
cb: (err: any, data?: CreateReplicatorCommandOutput) => void
406+
): void;
407+
361408
/**
362409
* @see {@link CreateVpcConnectionCommand}
363410
*/
@@ -420,6 +467,23 @@ export interface Kafka {
420467
cb: (err: any, data?: DeleteConfigurationCommandOutput) => void
421468
): void;
422469

470+
/**
471+
* @see {@link DeleteReplicatorCommand}
472+
*/
473+
deleteReplicator(
474+
args: DeleteReplicatorCommandInput,
475+
options?: __HttpHandlerOptions
476+
): Promise<DeleteReplicatorCommandOutput>;
477+
deleteReplicator(
478+
args: DeleteReplicatorCommandInput,
479+
cb: (err: any, data?: DeleteReplicatorCommandOutput) => void
480+
): void;
481+
deleteReplicator(
482+
args: DeleteReplicatorCommandInput,
483+
options: __HttpHandlerOptions,
484+
cb: (err: any, data?: DeleteReplicatorCommandOutput) => void
485+
): void;
486+
423487
/**
424488
* @see {@link DeleteVpcConnectionCommand}
425489
*/
@@ -536,6 +600,23 @@ export interface Kafka {
536600
cb: (err: any, data?: DescribeConfigurationRevisionCommandOutput) => void
537601
): void;
538602

603+
/**
604+
* @see {@link DescribeReplicatorCommand}
605+
*/
606+
describeReplicator(
607+
args: DescribeReplicatorCommandInput,
608+
options?: __HttpHandlerOptions
609+
): Promise<DescribeReplicatorCommandOutput>;
610+
describeReplicator(
611+
args: DescribeReplicatorCommandInput,
612+
cb: (err: any, data?: DescribeReplicatorCommandOutput) => void
613+
): void;
614+
describeReplicator(
615+
args: DescribeReplicatorCommandInput,
616+
options: __HttpHandlerOptions,
617+
cb: (err: any, data?: DescribeReplicatorCommandOutput) => void
618+
): void;
619+
539620
/**
540621
* @see {@link DescribeVpcConnectionCommand}
541622
*/
@@ -742,6 +823,20 @@ export interface Kafka {
742823
cb: (err: any, data?: ListNodesCommandOutput) => void
743824
): void;
744825

826+
/**
827+
* @see {@link ListReplicatorsCommand}
828+
*/
829+
listReplicators(
830+
args: ListReplicatorsCommandInput,
831+
options?: __HttpHandlerOptions
832+
): Promise<ListReplicatorsCommandOutput>;
833+
listReplicators(args: ListReplicatorsCommandInput, cb: (err: any, data?: ListReplicatorsCommandOutput) => void): void;
834+
listReplicators(
835+
args: ListReplicatorsCommandInput,
836+
options: __HttpHandlerOptions,
837+
cb: (err: any, data?: ListReplicatorsCommandOutput) => void
838+
): void;
839+
745840
/**
746841
* @see {@link ListScramSecretsCommand}
747842
*/
@@ -996,6 +1091,23 @@ export interface Kafka {
9961091
cb: (err: any, data?: UpdateMonitoringCommandOutput) => void
9971092
): void;
9981093

1094+
/**
1095+
* @see {@link UpdateReplicationInfoCommand}
1096+
*/
1097+
updateReplicationInfo(
1098+
args: UpdateReplicationInfoCommandInput,
1099+
options?: __HttpHandlerOptions
1100+
): Promise<UpdateReplicationInfoCommandOutput>;
1101+
updateReplicationInfo(
1102+
args: UpdateReplicationInfoCommandInput,
1103+
cb: (err: any, data?: UpdateReplicationInfoCommandOutput) => void
1104+
): void;
1105+
updateReplicationInfo(
1106+
args: UpdateReplicationInfoCommandInput,
1107+
options: __HttpHandlerOptions,
1108+
cb: (err: any, data?: UpdateReplicationInfoCommandOutput) => void
1109+
): void;
1110+
9991111
/**
10001112
* @see {@link UpdateSecurityCommand}
10011113
*/

0 commit comments

Comments
 (0)