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.
aws · Oct 17, 2023 · db53ab1 · db53ab1
1 parent 9a3a3f6
commit db53ab1
Show file tree

Hide file tree

Showing 15 changed files with 4,157 additions and 112 deletions.
diff --git a/clients/client-kafka/README.md b/clients/client-kafka/README.md
@@ -242,6 +242,14 @@ CreateConfiguration
 
 [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)
 
+</details>
+<details>
+<summary>
+CreateReplicator
+</summary>
+
+[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)
+
 </details>
 <details>
 <summary>
@@ -274,6 +282,14 @@ DeleteConfiguration
 
 [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)
 
+</details>
+<details>
+<summary>
+DeleteReplicator
+</summary>
+
+[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)
+
 </details>
 <details>
 <summary>
@@ -330,6 +346,14 @@ DescribeConfigurationRevision
 
 [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)
 
+</details>
+<details>
+<summary>
+DescribeReplicator
+</summary>
+
+[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)
+
 </details>
 <details>
 <summary>
@@ -434,6 +458,14 @@ ListNodes
 
 [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)
 
+</details>
+<details>
+<summary>
+ListReplicators
+</summary>
+
+[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)
+
 </details>
 <details>
 <summary>
@@ -562,6 +594,14 @@ UpdateMonitoring
 
 [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)
 
+</details>
+<details>
+<summary>
+UpdateReplicationInfo
+</summary>
+
+[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)
+
 </details>
 <details>
 <summary>

diff --git a/clients/client-kafka/src/Kafka.ts b/clients/client-kafka/src/Kafka.ts
@@ -27,6 +27,11 @@ import {
   CreateConfigurationCommandInput,
   CreateConfigurationCommandOutput,
 } from "./commands/CreateConfigurationCommand";
+import {
+  CreateReplicatorCommand,
+  CreateReplicatorCommandInput,
+  CreateReplicatorCommandOutput,
+} from "./commands/CreateReplicatorCommand";
 import {
   CreateVpcConnectionCommand,
   CreateVpcConnectionCommandInput,
@@ -47,6 +52,11 @@ import {
   DeleteConfigurationCommandInput,
   DeleteConfigurationCommandOutput,
 } from "./commands/DeleteConfigurationCommand";
+import {
+  DeleteReplicatorCommand,
+  DeleteReplicatorCommandInput,
+  DeleteReplicatorCommandOutput,
+} from "./commands/DeleteReplicatorCommand";
 import {
   DeleteVpcConnectionCommand,
   DeleteVpcConnectionCommandInput,
@@ -82,6 +92,11 @@ import {
   DescribeConfigurationRevisionCommandInput,
   DescribeConfigurationRevisionCommandOutput,
 } from "./commands/DescribeConfigurationRevisionCommand";
+import {
+  DescribeReplicatorCommand,
+  DescribeReplicatorCommandInput,
+  DescribeReplicatorCommandOutput,
+} from "./commands/DescribeReplicatorCommand";
 import {
   DescribeVpcConnectionCommand,
   DescribeVpcConnectionCommandInput,
@@ -143,6 +158,11 @@ import {
   ListKafkaVersionsCommandOutput,
 } from "./commands/ListKafkaVersionsCommand";
 import { ListNodesCommand, ListNodesCommandInput, ListNodesCommandOutput } from "./commands/ListNodesCommand";
+import {
+  ListReplicatorsCommand,
+  ListReplicatorsCommandInput,
+  ListReplicatorsCommandOutput,
+} from "./commands/ListReplicatorsCommand";
 import {
   ListScramSecretsCommand,
   ListScramSecretsCommandInput,
@@ -219,6 +239,11 @@ import {
   UpdateMonitoringCommandInput,
   UpdateMonitoringCommandOutput,
 } from "./commands/UpdateMonitoringCommand";
+import {
+  UpdateReplicationInfoCommand,
+  UpdateReplicationInfoCommandInput,
+  UpdateReplicationInfoCommandOutput,
+} from "./commands/UpdateReplicationInfoCommand";
 import {
   UpdateSecurityCommand,
   UpdateSecurityCommandInput,
@@ -237,17 +262,20 @@ const commands = {
   CreateClusterCommand,
   CreateClusterV2Command,
   CreateConfigurationCommand,
+  CreateReplicatorCommand,
   CreateVpcConnectionCommand,
   DeleteClusterCommand,
   DeleteClusterPolicyCommand,
   DeleteConfigurationCommand,
+  DeleteReplicatorCommand,
   DeleteVpcConnectionCommand,
   DescribeClusterCommand,
   DescribeClusterOperationCommand,
   DescribeClusterOperationV2Command,
   DescribeClusterV2Command,
   DescribeConfigurationCommand,
   DescribeConfigurationRevisionCommand,
+  DescribeReplicatorCommand,
   DescribeVpcConnectionCommand,
   GetBootstrapBrokersCommand,
   GetClusterPolicyCommand,
@@ -261,6 +289,7 @@ const commands = {
   ListConfigurationsCommand,
   ListKafkaVersionsCommand,
   ListNodesCommand,
+  ListReplicatorsCommand,
   ListScramSecretsCommand,
   ListTagsForResourceCommand,
   ListVpcConnectionsCommand,
@@ -277,6 +306,7 @@ const commands = {
   UpdateConfigurationCommand,
   UpdateConnectivityCommand,
   UpdateMonitoringCommand,
+  UpdateReplicationInfoCommand,
   UpdateSecurityCommand,
   UpdateStorageCommand,
 };
@@ -358,6 +388,23 @@ export interface Kafka {
     cb: (err: any, data?: CreateConfigurationCommandOutput) => void
   ): void;
 
+  /**
+   * @see {@link CreateReplicatorCommand}
+   */
+  createReplicator(
+    args: CreateReplicatorCommandInput,
+    options?: __HttpHandlerOptions
+  ): Promise<CreateReplicatorCommandOutput>;
+  createReplicator(
+    args: CreateReplicatorCommandInput,
+    cb: (err: any, data?: CreateReplicatorCommandOutput) => void
+  ): void;
+  createReplicator(
+    args: CreateReplicatorCommandInput,
+    options: __HttpHandlerOptions,
+    cb: (err: any, data?: CreateReplicatorCommandOutput) => void
+  ): void;
+
   /**
    * @see {@link CreateVpcConnectionCommand}
    */
@@ -420,6 +467,23 @@ export interface Kafka {
     cb: (err: any, data?: DeleteConfigurationCommandOutput) => void
   ): void;
 
+  /**
+   * @see {@link DeleteReplicatorCommand}
+   */
+  deleteReplicator(
+    args: DeleteReplicatorCommandInput,
+    options?: __HttpHandlerOptions
+  ): Promise<DeleteReplicatorCommandOutput>;
+  deleteReplicator(
+    args: DeleteReplicatorCommandInput,
+    cb: (err: any, data?: DeleteReplicatorCommandOutput) => void
+  ): void;
+  deleteReplicator(
+    args: DeleteReplicatorCommandInput,
+    options: __HttpHandlerOptions,
+    cb: (err: any, data?: DeleteReplicatorCommandOutput) => void
+  ): void;
+
   /**
    * @see {@link DeleteVpcConnectionCommand}
    */
@@ -536,6 +600,23 @@ export interface Kafka {
     cb: (err: any, data?: DescribeConfigurationRevisionCommandOutput) => void
   ): void;
 
+  /**
+   * @see {@link DescribeReplicatorCommand}
+   */
+  describeReplicator(
+    args: DescribeReplicatorCommandInput,
+    options?: __HttpHandlerOptions
+  ): Promise<DescribeReplicatorCommandOutput>;
+  describeReplicator(
+    args: DescribeReplicatorCommandInput,
+    cb: (err: any, data?: DescribeReplicatorCommandOutput) => void
+  ): void;
+  describeReplicator(
+    args: DescribeReplicatorCommandInput,
+    options: __HttpHandlerOptions,
+    cb: (err: any, data?: DescribeReplicatorCommandOutput) => void
+  ): void;
+
   /**
    * @see {@link DescribeVpcConnectionCommand}
    */
@@ -742,6 +823,20 @@ export interface Kafka {
     cb: (err: any, data?: ListNodesCommandOutput) => void
   ): void;
 
+  /**
+   * @see {@link ListReplicatorsCommand}
+   */
+  listReplicators(
+    args: ListReplicatorsCommandInput,
+    options?: __HttpHandlerOptions
+  ): Promise<ListReplicatorsCommandOutput>;
+  listReplicators(args: ListReplicatorsCommandInput, cb: (err: any, data?: ListReplicatorsCommandOutput) => void): void;
+  listReplicators(
+    args: ListReplicatorsCommandInput,
+    options: __HttpHandlerOptions,
+    cb: (err: any, data?: ListReplicatorsCommandOutput) => void
+  ): void;
+
   /**
    * @see {@link ListScramSecretsCommand}
    */
@@ -996,6 +1091,23 @@ export interface Kafka {
     cb: (err: any, data?: UpdateMonitoringCommandOutput) => void
   ): void;
 
+  /**
+   * @see {@link UpdateReplicationInfoCommand}
+   */
+  updateReplicationInfo(
+    args: UpdateReplicationInfoCommandInput,
+    options?: __HttpHandlerOptions
+  ): Promise<UpdateReplicationInfoCommandOutput>;
+  updateReplicationInfo(
+    args: UpdateReplicationInfoCommandInput,
+    cb: (err: any, data?: UpdateReplicationInfoCommandOutput) => void
+  ): void;
+  updateReplicationInfo(
+    args: UpdateReplicationInfoCommandInput,
+    options: __HttpHandlerOptions,
+    cb: (err: any, data?: UpdateReplicationInfoCommandOutput) => void
+  ): void;
+
   /**
    * @see {@link UpdateSecurityCommand}
    */