feat(client-kafka): Added support for specifying the starting position of topic replication in MSK-Replicator.

Author: awstools

clients/client-kafka/src/commands/CreateReplicatorCommand.ts

@@ -71,6 +71,9 @@ export interface CreateReplicatorCommandOutput extends CreateReplicatorResponse,
  *         CopyAccessControlListsForTopics: true || false,
  *         CopyTopicConfigurations: true || false,
  *         DetectAndCopyNewTopics: true || false,
+ *         StartingPosition: { // ReplicationStartingPosition
+ *           Type: "LATEST" || "EARLIEST",
+ *         },
  *         TopicsToExclude: [ // __listOf__stringMax249
  *           "STRING_VALUE",
  *         ],

clients/client-kafka/src/commands/DescribeReplicatorCommand.ts

@@ -79,6 +79,9 @@ export interface DescribeReplicatorCommandOutput extends DescribeReplicatorRespo
  * //         CopyAccessControlListsForTopics: true || false,
  * //         CopyTopicConfigurations: true || false,
  * //         DetectAndCopyNewTopics: true || false,
+ * //         StartingPosition: { // ReplicationStartingPosition
+ * //           Type: "LATEST" || "EARLIEST",
+ * //         },
  * //         TopicsToExclude: [ // __listOf__stringMax249
  * //           "STRING_VALUE",
  * //         ],

clients/client-kafka/src/models/models_0.ts

@@ -1789,6 +1789,33 @@ export const TargetCompressionType = {
  */
 export type TargetCompressionType = (typeof TargetCompressionType)[keyof typeof TargetCompressionType];
 
+/**
+ * @public
+ * @enum
+ */
+export const ReplicationStartingPositionType = {
+  EARLIEST: "EARLIEST",
+  LATEST: "LATEST",
+} as const;
+
+/**
+ * @public
+ */
+export type ReplicationStartingPositionType =
+  (typeof ReplicationStartingPositionType)[keyof typeof ReplicationStartingPositionType];
+
+/**
+ * @public
+ * <p>Configuration for specifying the position in the topics to start replicating from.</p>
+ */
+export interface ReplicationStartingPosition {
+  /**
+   * @public
+   * <p>The type of replication starting position.</p>
+   */
+  Type?: ReplicationStartingPositionType;
+}
+
 /**
  * @public
  * <p>Details about topic replication.</p>
@@ -1812,6 +1839,12 @@ export interface TopicReplication {
    */
   DetectAndCopyNewTopics?: boolean;
 
+  /**
+   * @public
+   * <p>Configuration for specifying the position in the topics to start replicating from.</p>
+   */
+  StartingPosition?: ReplicationStartingPosition;
+
   /**
    * @public
    * <p>List of regular expression patterns indicating the topics that should not be replicated.</p>

clients/client-kafka/src/protocols/Aws_restJson1.ts

@@ -215,6 +215,7 @@ import {
   ReplicationInfo,
   ReplicationInfoDescription,
   ReplicationInfoSummary,
+  ReplicationStartingPosition,
   ReplicationStateInfo,
   ReplicatorSummary,
   S3,
@@ -3040,6 +3041,15 @@ const se_ReplicationInfo = (input: ReplicationInfo, context: __SerdeContext): an
   });
 };
 
+/**
+ * serializeAws_restJson1ReplicationStartingPosition
+ */
+const se_ReplicationStartingPosition = (input: ReplicationStartingPosition, context: __SerdeContext): any => {
+  return take(input, {
+    type: [, , `Type`],
+  });
+};
+
 /**
  * serializeAws_restJson1S3
  */
@@ -3125,6 +3135,7 @@ const se_TopicReplication = (input: TopicReplication, context: __SerdeContext):
     copyAccessControlListsForTopics: [, , `CopyAccessControlListsForTopics`],
     copyTopicConfigurations: [, , `CopyTopicConfigurations`],
     detectAndCopyNewTopics: [, , `DetectAndCopyNewTopics`],
+    startingPosition: [, (_) => se_ReplicationStartingPosition(_, context), `StartingPosition`],
     topicsToExclude: [, _json, `TopicsToExclude`],
     topicsToReplicate: [, _json, `TopicsToReplicate`],
   });
@@ -4070,6 +4081,15 @@ const de_ReplicationInfoSummary = (output: any, context: __SerdeContext): Replic
   }) as any;
 };
 
+/**
+ * deserializeAws_restJson1ReplicationStartingPosition
+ */
+const de_ReplicationStartingPosition = (output: any, context: __SerdeContext): ReplicationStartingPosition => {
+  return take(output, {
+    Type: [, __expectString, `type`],
+  }) as any;
+};
+
 /**
  * deserializeAws_restJson1ReplicationStateInfo
  */
@@ -4196,6 +4216,7 @@ const de_TopicReplication = (output: any, context: __SerdeContext): TopicReplica
     CopyAccessControlListsForTopics: [, __expectBoolean, `copyAccessControlListsForTopics`],
     CopyTopicConfigurations: [, __expectBoolean, `copyTopicConfigurations`],
     DetectAndCopyNewTopics: [, __expectBoolean, `detectAndCopyNewTopics`],
+    StartingPosition: [, (_: any) => de_ReplicationStartingPosition(_, context), `startingPosition`],
     TopicsToExclude: [, _json, `topicsToExclude`],
     TopicsToReplicate: [, _json, `topicsToReplicate`],
   }) as any;

codegen/sdk-codegen/aws-models/kafka.json

@@ -7145,6 +7145,41 @@
         "smithy.api#documentation": "<p>Summarized information of replication between clusters.</p>"
       }
     },
+    "com.amazonaws.kafka#ReplicationStartingPosition": {
+      "type": "structure",
+      "members": {
+        "Type": {
+          "target": "com.amazonaws.kafka#ReplicationStartingPositionType",
+          "traits": {
+            "smithy.api#documentation": "<p>The type of replication starting position.</p>",
+            "smithy.api#jsonName": "type"
+          }
+        }
+      },
+      "traits": {
+        "smithy.api#documentation": "<p>Configuration for specifying the position in the topics to start replicating from.</p>"
+      }
+    },
+    "com.amazonaws.kafka#ReplicationStartingPositionType": {
+      "type": "enum",
+      "members": {
+        "LATEST": {
+          "target": "smithy.api#Unit",
+          "traits": {
+            "smithy.api#enumValue": "LATEST"
+          }
+        },
+        "EARLIEST": {
+          "target": "smithy.api#Unit",
+          "traits": {
+            "smithy.api#enumValue": "EARLIEST"
+          }
+        }
+      },
+      "traits": {
+        "smithy.api#documentation": "<p>The type of replication starting position.</p>"
+      }
+    },
     "com.amazonaws.kafka#ReplicationStateInfo": {
       "type": "structure",
       "members": {
@@ -7653,6 +7688,13 @@
             "smithy.api#jsonName": "detectAndCopyNewTopics"
           }
         },
+        "StartingPosition": {
+          "target": "com.amazonaws.kafka#ReplicationStartingPosition",
+          "traits": {
+            "smithy.api#documentation": "<p>Configuration for specifying the position in the topics to start replicating from.</p>",
+            "smithy.api#jsonName": "startingPosition"
+          }
+        },
         "TopicsToExclude": {
           "target": "com.amazonaws.kafka#__listOf__stringMax249",
           "traits": {