diff --git a/CHANGELOG.md b/CHANGELOG.md
index 96b3a85ce0a..21938943b58 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,3 +1,14 @@
+Release v1.50.26 (2024-02-26)
+===
+
+### Service Client Updates
+* `service/apigateway`: Updates service documentation
+  * Documentation updates for Amazon API Gateway.
+* `service/drs`: Updates service API and documentation
+* `service/kafkaconnect`: Updates service API and documentation
+* `service/rds`: Updates service API, documentation, waiters, paginators, and examples
+  * This release adds support for gp3 data volumes for Multi-AZ DB Clusters.
+
 Release v1.50.25 (2024-02-23)
 ===
 
diff --git a/aws/version.go b/aws/version.go
index e0267957552..ed0729d446b 100644
--- a/aws/version.go
+++ b/aws/version.go
@@ -5,4 +5,4 @@ package aws
 const SDKName = "aws-sdk-go"
 
 // SDKVersion is the version of this SDK
-const SDKVersion = "1.50.25"
+const SDKVersion = "1.50.26"
diff --git a/models/apis/apigateway/2015-07-09/docs-2.json b/models/apis/apigateway/2015-07-09/docs-2.json
index c11169fc467..b9b87327e54 100644
--- a/models/apis/apigateway/2015-07-09/docs-2.json
+++ b/models/apis/apigateway/2015-07-09/docs-2.json
@@ -114,7 +114,7 @@
     "UpdateIntegrationResponse": "<p>Represents an update integration response.</p>",
     "UpdateMethod": "<p>Updates an existing Method resource.</p>",
     "UpdateMethodResponse": "<p>Updates an existing MethodResponse resource.</p>",
-    "UpdateModel": "<p>Changes information about a model.</p>",
+    "UpdateModel": "<p>Changes information about a model. The maximum size of the model is 400 KB.</p>",
     "UpdateRequestValidator": "<p>Updates a RequestValidator of a given RestApi.</p>",
     "UpdateResource": "<p>Changes information about a Resource resource.</p>",
     "UpdateRestApi": "<p>Changes information about the specified API.</p>",
@@ -245,7 +245,7 @@
         "RequestValidator$validateRequestParameters": "<p>A Boolean flag to indicate whether to validate request parameters (<code>true</code>) or not (<code>false</code>).</p>",
         "RestApi$disableExecuteApiEndpoint": "<p>Specifies whether clients can invoke your API by using the default <code>execute-api</code> endpoint. By default, clients can invoke your API with the default <code>https://{api_id}.execute-api.{region}.amazonaws.com</code> endpoint. To require that clients use a custom domain name to invoke your API, disable the default endpoint.</p>",
         "SdkConfigurationProperty$required": "<p>A boolean flag of an SdkType configuration property to indicate if the associated SDK configuration property is required (<code>true</code>) or not (<code>false</code>).</p>",
-        "Stage$cacheClusterEnabled": "<p>Specifies whether a cache cluster is enabled for the stage.</p>",
+        "Stage$cacheClusterEnabled": "<p>Specifies whether a cache cluster is enabled for the stage. To activate a method-level cache, set <code>CachingEnabled</code> to <code>true</code> for a method. </p>",
         "Stage$tracingEnabled": "<p>Specifies whether active tracing with X-ray is enabled for the Stage.</p>",
         "TlsConfig$insecureSkipVerification": "<p>Specifies whether or not API Gateway skips verification that the certificate for an integration endpoint is issued by a supported certificate authority. This isn’t recommended, but it enables you to use certificates that are signed by private certificate authorities, or certificates that are self-signed. If enabled, API Gateway still performs basic certificate validation, which includes checking the certificate's expiration date, hostname, and presence of a root certificate authority. Supported only for <code>HTTP</code> and <code>HTTP_PROXY</code> integrations.</p> <important> <p>Enabling <code>insecureSkipVerification</code> isn't recommended, especially for integrations with public HTTPS endpoints. If you enable <code>insecureSkipVerification</code>, you increase the risk of man-in-the-middle attacks.</p> </important>"
       }
@@ -1583,7 +1583,7 @@
         "CreateModelRequest$restApiId": "<p>The RestApi identifier under which the Model will be created.</p>",
         "CreateModelRequest$name": "<p>The name of the model. Must be alphanumeric.</p>",
         "CreateModelRequest$description": "<p>The description of the model.</p>",
-        "CreateModelRequest$schema": "<p>The schema for the model. For <code>application/json</code> models, this should be JSON schema draft 4 model.</p>",
+        "CreateModelRequest$schema": "<p>The schema for the model. For <code>application/json</code> models, this should be JSON schema draft 4 model. The maximum size of the model is 400 KB.</p>",
         "CreateModelRequest$contentType": "<p>The content-type for the model.</p>",
         "CreateRequestValidatorRequest$restApiId": "<p>The string identifier of the associated RestApi.</p>",
         "CreateRequestValidatorRequest$name": "<p>The name of the to-be-created RequestValidator.</p>",
diff --git a/models/apis/apigateway/2015-07-09/endpoint-rule-set-1.json b/models/apis/apigateway/2015-07-09/endpoint-rule-set-1.json
index 61804152356..c8acc7bd13a 100644
--- a/models/apis/apigateway/2015-07-09/endpoint-rule-set-1.json
+++ b/models/apis/apigateway/2015-07-09/endpoint-rule-set-1.json
@@ -40,7 +40,6 @@
                     ]
                 }
             ],
-            "type": "tree",
             "rules": [
                 {
                     "conditions": [
@@ -83,7 +82,8 @@
                     },
                     "type": "endpoint"
                 }
-            ]
+            ],
+            "type": "tree"
         },
         {
             "conditions": [
@@ -96,7 +96,6 @@
                     ]
                 }
             ],
-            "type": "tree",
             "rules": [
                 {
                     "conditions": [
@@ -110,7 +109,6 @@
                             "assign": "PartitionResult"
                         }
                     ],
-                    "type": "tree",
                     "rules": [
                         {
                             "conditions": [
@@ -133,7 +131,6 @@
                                     ]
                                 }
                             ],
-                            "type": "tree",
                             "rules": [
                                 {
                                     "conditions": [
@@ -168,7 +165,6 @@
                                             ]
                                         }
                                     ],
-                                    "type": "tree",
                                     "rules": [
                                         {
                                             "conditions": [],
@@ -179,14 +175,16 @@
                                             },
                                             "type": "endpoint"
                                         }
-                                    ]
+                                    ],
+                                    "type": "tree"
                                 },
                                 {
                                     "conditions": [],
                                     "error": "FIPS and DualStack are enabled, but this partition does not support one or both",
                                     "type": "error"
                                 }
-                            ]
+                            ],
+                            "type": "tree"
                         },
                         {
                             "conditions": [
@@ -200,14 +198,12 @@
                                     ]
                                 }
                             ],
-                            "type": "tree",
                             "rules": [
                                 {
                                     "conditions": [
                                         {
                                             "fn": "booleanEquals",
                                             "argv": [
-                                                true,
                                                 {
                                                     "fn": "getAttr",
                                                     "argv": [
@@ -216,11 +212,11 @@
                                                         },
                                                         "supportsFIPS"
                                                     ]
-                                                }
+                                                },
+                                                true
                                             ]
                                         }
                                     ],
-                                    "type": "tree",
                                     "rules": [
                                         {
                                             "conditions": [],
@@ -231,14 +227,16 @@
                                             },
                                             "type": "endpoint"
                                         }
-                                    ]
+                                    ],
+                                    "type": "tree"
                                 },
                                 {
                                     "conditions": [],
                                     "error": "FIPS is enabled but this partition does not support FIPS",
                                     "type": "error"
                                 }
-                            ]
+                            ],
+                            "type": "tree"
                         },
                         {
                             "conditions": [
@@ -252,7 +250,6 @@
                                     ]
                                 }
                             ],
-                            "type": "tree",
                             "rules": [
                                 {
                                     "conditions": [
@@ -272,7 +269,6 @@
                                             ]
                                         }
                                     ],
-                                    "type": "tree",
                                     "rules": [
                                         {
                                             "conditions": [],
@@ -283,14 +279,16 @@
                                             },
                                             "type": "endpoint"
                                         }
-                                    ]
+                                    ],
+                                    "type": "tree"
                                 },
                                 {
                                     "conditions": [],
                                     "error": "DualStack is enabled but this partition does not support DualStack",
                                     "type": "error"
                                 }
-                            ]
+                            ],
+                            "type": "tree"
                         },
                         {
                             "conditions": [],
@@ -301,9 +299,11 @@
                             },
                             "type": "endpoint"
                         }
-                    ]
+                    ],
+                    "type": "tree"
                 }
-            ]
+            ],
+            "type": "tree"
         },
         {
             "conditions": [],
diff --git a/models/apis/drs/2020-02-26/api-2.json b/models/apis/drs/2020-02-26/api-2.json
index f82267b2347..a6bd6bc41fc 100644
--- a/models/apis/drs/2020-02-26/api-2.json
+++ b/models/apis/drs/2020-02-26/api-2.json
@@ -1006,6 +1006,7 @@
         "forceUefi":{"shape":"Boolean"},
         "rootVolumeName":{"shape":"LargeBoundedString"},
         "volumeToConversionMap":{"shape":"VolumeToConversionMap"},
+        "volumeToProductCodes":{"shape":"VolumeToProductCodes"},
         "volumeToVolumeSize":{"shape":"VolumeToSizeMap"}
       }
     },
@@ -1148,7 +1149,8 @@
         "deviceName":{"shape":"BoundedString"},
         "replicatedStorageBytes":{"shape":"PositiveInteger"},
         "rescannedStorageBytes":{"shape":"PositiveInteger"},
-        "totalStorageBytes":{"shape":"PositiveInteger"}
+        "totalStorageBytes":{"shape":"PositiveInteger"},
+        "volumeStatus":{"shape":"VolumeStatus"}
       }
     },
     "DataReplicationInfoReplicatedDisks":{
@@ -2280,6 +2282,30 @@
       "type":"long",
       "min":0
     },
+    "ProductCode":{
+      "type":"structure",
+      "members":{
+        "productCodeId":{"shape":"ProductCodeId"},
+        "productCodeMode":{"shape":"ProductCodeMode"}
+      }
+    },
+    "ProductCodeId":{
+      "type":"string",
+      "max":25,
+      "min":25,
+      "pattern":"^([A-Za-z0-9])+$"
+    },
+    "ProductCodeMode":{
+      "type":"string",
+      "enum":[
+        "ENABLED",
+        "DISABLED"
+      ]
+    },
+    "ProductCodes":{
+      "type":"list",
+      "member":{"shape":"ProductCode"}
+    },
     "PutLaunchActionRequest":{
       "type":"structure",
       "required":[
@@ -3271,11 +3297,25 @@
         "other"
       ]
     },
+    "VolumeStatus":{
+      "type":"string",
+      "enum":[
+        "REGULAR",
+        "CONTAINS_MARKETPLACE_PRODUCT_CODES",
+        "MISSING_VOLUME_ATTRIBUTES",
+        "MISSING_VOLUME_ATTRIBUTES_AND_PRECHECK_UNAVAILABLE"
+      ]
+    },
     "VolumeToConversionMap":{
       "type":"map",
       "key":{"shape":"LargeBoundedString"},
       "value":{"shape":"ConversionMap"}
     },
+    "VolumeToProductCodes":{
+      "type":"map",
+      "key":{"shape":"LargeBoundedString"},
+      "value":{"shape":"ProductCodes"}
+    },
     "VolumeToSizeMap":{
       "type":"map",
       "key":{"shape":"LargeBoundedString"},
diff --git a/models/apis/drs/2020-02-26/docs-2.json b/models/apis/drs/2020-02-26/docs-2.json
index 9fa9577e088..db3db46a702 100644
--- a/models/apis/drs/2020-02-26/docs-2.json
+++ b/models/apis/drs/2020-02-26/docs-2.json
@@ -885,6 +885,7 @@
         "ValidationExceptionField$message": "<p>Validate exception field message.</p>",
         "ValidationExceptionField$name": "<p>Validate exception field name.</p>",
         "VolumeToConversionMap$key": null,
+        "VolumeToProductCodes$key": null,
         "VolumeToSizeMap$key": null
       }
     },
@@ -1334,6 +1335,30 @@
         "VolumeToSizeMap$value": null
       }
     },
+    "ProductCode": {
+      "base": "<p>Properties of a product code associated with a volume.</p>",
+      "refs": {
+        "ProductCodes$member": null
+      }
+    },
+    "ProductCodeId": {
+      "base": null,
+      "refs": {
+        "ProductCode$productCodeId": "<p>Id of a product code associated with a volume.</p>"
+      }
+    },
+    "ProductCodeMode": {
+      "base": null,
+      "refs": {
+        "ProductCode$productCodeMode": "<p>Mode of a product code associated with a volume.</p>"
+      }
+    },
+    "ProductCodes": {
+      "base": null,
+      "refs": {
+        "VolumeToProductCodes$value": null
+      }
+    },
     "PutLaunchActionRequest": {
       "base": null,
       "refs": {
@@ -2054,12 +2079,24 @@
         "ValidationException$reason": "<p>Validation exception reason.</p>"
       }
     },
+    "VolumeStatus": {
+      "base": null,
+      "refs": {
+        "DataReplicationInfoReplicatedDisk$volumeStatus": "<p>The status of the volume.</p>"
+      }
+    },
     "VolumeToConversionMap": {
       "base": null,
       "refs": {
         "ConversionProperties$volumeToConversionMap": "<p>A mapping between the volumes being converted and the converted snapshot ids</p>"
       }
     },
+    "VolumeToProductCodes": {
+      "base": null,
+      "refs": {
+        "ConversionProperties$volumeToProductCodes": "<p>A mapping between the volumes being converted and the product codes associated with them</p>"
+      }
+    },
     "VolumeToSizeMap": {
       "base": null,
       "refs": {
diff --git a/models/apis/kafkaconnect/2021-09-14/api-2.json b/models/apis/kafkaconnect/2021-09-14/api-2.json
index 8632fb1dd48..62234e4f0c4 100644
--- a/models/apis/kafkaconnect/2021-09-14/api-2.json
+++ b/models/apis/kafkaconnect/2021-09-14/api-2.json
@@ -113,6 +113,26 @@
       ],
       "idempotent":true
     },
+    "DeleteWorkerConfiguration":{
+      "name":"DeleteWorkerConfiguration",
+      "http":{
+        "method":"DELETE",
+        "requestUri":"/v1/worker-configurations/{workerConfigurationArn}",
+        "responseCode":200
+      },
+      "input":{"shape":"DeleteWorkerConfigurationRequest"},
+      "output":{"shape":"DeleteWorkerConfigurationResponse"},
+      "errors":[
+        {"shape":"NotFoundException"},
+        {"shape":"BadRequestException"},
+        {"shape":"ForbiddenException"},
+        {"shape":"ServiceUnavailableException"},
+        {"shape":"TooManyRequestsException"},
+        {"shape":"UnauthorizedException"},
+        {"shape":"InternalServerErrorException"}
+      ],
+      "idempotent":true
+    },
     "DescribeConnector":{
       "name":"DescribeConnector",
       "http":{
@@ -208,6 +228,25 @@
         {"shape":"InternalServerErrorException"}
       ]
     },
+    "ListTagsForResource":{
+      "name":"ListTagsForResource",
+      "http":{
+        "method":"GET",
+        "requestUri":"/v1/tags/{resourceArn}",
+        "responseCode":200
+      },
+      "input":{"shape":"ListTagsForResourceRequest"},
+      "output":{"shape":"ListTagsForResourceResponse"},
+      "errors":[
+        {"shape":"NotFoundException"},
+        {"shape":"BadRequestException"},
+        {"shape":"ForbiddenException"},
+        {"shape":"ServiceUnavailableException"},
+        {"shape":"TooManyRequestsException"},
+        {"shape":"UnauthorizedException"},
+        {"shape":"InternalServerErrorException"}
+      ]
+    },
     "ListWorkerConfigurations":{
       "name":"ListWorkerConfigurations",
       "http":{
@@ -227,6 +266,47 @@
         {"shape":"InternalServerErrorException"}
       ]
     },
+    "TagResource":{
+      "name":"TagResource",
+      "http":{
+        "method":"POST",
+        "requestUri":"/v1/tags/{resourceArn}",
+        "responseCode":200
+      },
+      "input":{"shape":"TagResourceRequest"},
+      "output":{"shape":"TagResourceResponse"},
+      "errors":[
+        {"shape":"NotFoundException"},
+        {"shape":"ConflictException"},
+        {"shape":"BadRequestException"},
+        {"shape":"ForbiddenException"},
+        {"shape":"ServiceUnavailableException"},
+        {"shape":"TooManyRequestsException"},
+        {"shape":"UnauthorizedException"},
+        {"shape":"InternalServerErrorException"}
+      ],
+      "idempotent":true
+    },
+    "UntagResource":{
+      "name":"UntagResource",
+      "http":{
+        "method":"DELETE",
+        "requestUri":"/v1/tags/{resourceArn}",
+        "responseCode":200
+      },
+      "input":{"shape":"UntagResourceRequest"},
+      "output":{"shape":"UntagResourceResponse"},
+      "errors":[
+        {"shape":"NotFoundException"},
+        {"shape":"BadRequestException"},
+        {"shape":"ForbiddenException"},
+        {"shape":"ServiceUnavailableException"},
+        {"shape":"TooManyRequestsException"},
+        {"shape":"UnauthorizedException"},
+        {"shape":"InternalServerErrorException"}
+      ],
+      "idempotent":true
+    },
     "UpdateConnector":{
       "name":"UpdateConnector",
       "http":{
@@ -422,6 +502,7 @@
         "logDelivery":{"shape":"LogDelivery"},
         "plugins":{"shape":"__listOfPlugin"},
         "serviceExecutionRoleArn":{"shape":"__string"},
+        "tags":{"shape":"Tags"},
         "workerConfiguration":{"shape":"WorkerConfiguration"}
       }
     },
@@ -444,7 +525,8 @@
         "contentType":{"shape":"CustomPluginContentType"},
         "description":{"shape":"__stringMax1024"},
         "location":{"shape":"CustomPluginLocation"},
-        "name":{"shape":"__stringMin1Max128"}
+        "name":{"shape":"__stringMin1Max128"},
+        "tags":{"shape":"Tags"}
       }
     },
     "CreateCustomPluginResponse":{
@@ -465,7 +547,8 @@
       "members":{
         "description":{"shape":"__stringMax1024"},
         "name":{"shape":"__stringMin1Max128"},
-        "propertiesFileContent":{"shape":"__sensitiveString"}
+        "propertiesFileContent":{"shape":"__sensitiveString"},
+        "tags":{"shape":"Tags"}
       }
     },
     "CreateWorkerConfigurationResponse":{
@@ -474,7 +557,8 @@
         "creationTime":{"shape":"__timestampIso8601"},
         "latestRevision":{"shape":"WorkerConfigurationRevisionSummary"},
         "name":{"shape":"__string"},
-        "workerConfigurationArn":{"shape":"__string"}
+        "workerConfigurationArn":{"shape":"__string"},
+        "workerConfigurationState":{"shape":"WorkerConfigurationState"}
       }
     },
     "CustomPlugin":{
@@ -596,6 +680,24 @@
         "customPluginState":{"shape":"CustomPluginState"}
       }
     },
+    "DeleteWorkerConfigurationRequest":{
+      "type":"structure",
+      "required":["workerConfigurationArn"],
+      "members":{
+        "workerConfigurationArn":{
+          "shape":"__string",
+          "location":"uri",
+          "locationName":"workerConfigurationArn"
+        }
+      }
+    },
+    "DeleteWorkerConfigurationResponse":{
+      "type":"structure",
+      "members":{
+        "workerConfigurationArn":{"shape":"__string"},
+        "workerConfigurationState":{"shape":"WorkerConfigurationState"}
+      }
+    },
     "DescribeConnectorRequest":{
       "type":"structure",
       "required":["connectorArn"],
@@ -670,7 +772,8 @@
         "description":{"shape":"__string"},
         "latestRevision":{"shape":"WorkerConfigurationRevisionDescription"},
         "name":{"shape":"__string"},
-        "workerConfigurationArn":{"shape":"__string"}
+        "workerConfigurationArn":{"shape":"__string"},
+        "workerConfigurationState":{"shape":"WorkerConfigurationState"}
       }
     },
     "FirehoseLogDelivery":{
@@ -796,6 +899,11 @@
           "location":"querystring",
           "locationName":"maxResults"
         },
+        "namePrefix":{
+          "shape":"__string",
+          "location":"querystring",
+          "locationName":"namePrefix"
+        },
         "nextToken":{
           "shape":"__string",
           "location":"querystring",
@@ -810,6 +918,23 @@
         "nextToken":{"shape":"__string"}
       }
     },
+    "ListTagsForResourceRequest":{
+      "type":"structure",
+      "required":["resourceArn"],
+      "members":{
+        "resourceArn":{
+          "shape":"__string",
+          "location":"uri",
+          "locationName":"resourceArn"
+        }
+      }
+    },
+    "ListTagsForResourceResponse":{
+      "type":"structure",
+      "members":{
+        "tags":{"shape":"Tags"}
+      }
+    },
     "ListWorkerConfigurationsRequest":{
       "type":"structure",
       "members":{
@@ -818,6 +943,11 @@
           "location":"querystring",
           "locationName":"maxResults"
         },
+        "namePrefix":{
+          "shape":"__string",
+          "location":"querystring",
+          "locationName":"namePrefix"
+        },
         "nextToken":{
           "shape":"__string",
           "location":"querystring",
@@ -996,6 +1126,49 @@
         "message":{"shape":"__string"}
       }
     },
+    "TagKey":{
+      "type":"string",
+      "max":128,
+      "min":1
+    },
+    "TagKeyList":{
+      "type":"list",
+      "member":{"shape":"TagKey"},
+      "max":200,
+      "min":0
+    },
+    "TagResourceRequest":{
+      "type":"structure",
+      "required":[
+        "resourceArn",
+        "tags"
+      ],
+      "members":{
+        "resourceArn":{
+          "shape":"__string",
+          "location":"uri",
+          "locationName":"resourceArn"
+        },
+        "tags":{"shape":"Tags"}
+      }
+    },
+    "TagResourceResponse":{
+      "type":"structure",
+      "members":{
+      }
+    },
+    "TagValue":{
+      "type":"string",
+      "max":256,
+      "min":0
+    },
+    "Tags":{
+      "type":"map",
+      "key":{"shape":"TagKey"},
+      "value":{"shape":"TagValue"},
+      "max":200,
+      "min":0
+    },
     "TooManyRequestsException":{
       "type":"structure",
       "members":{
@@ -1018,6 +1191,30 @@
       },
       "exception":true
     },
+    "UntagResourceRequest":{
+      "type":"structure",
+      "required":[
+        "resourceArn",
+        "tagKeys"
+      ],
+      "members":{
+        "resourceArn":{
+          "shape":"__string",
+          "location":"uri",
+          "locationName":"resourceArn"
+        },
+        "tagKeys":{
+          "shape":"TagKeyList",
+          "location":"querystring",
+          "locationName":"tagKeys"
+        }
+      }
+    },
+    "UntagResourceResponse":{
+      "type":"structure",
+      "members":{
+      }
+    },
     "UpdateConnectorRequest":{
       "type":"structure",
       "required":[
@@ -1096,6 +1293,13 @@
         "revision":{"shape":"__long"}
       }
     },
+    "WorkerConfigurationState":{
+      "type":"string",
+      "enum":[
+        "ACTIVE",
+        "DELETING"
+      ]
+    },
     "WorkerConfigurationSummary":{
       "type":"structure",
       "members":{
@@ -1103,7 +1307,8 @@
         "description":{"shape":"__string"},
         "latestRevision":{"shape":"WorkerConfigurationRevisionSummary"},
         "name":{"shape":"__string"},
-        "workerConfigurationArn":{"shape":"__string"}
+        "workerConfigurationArn":{"shape":"__string"},
+        "workerConfigurationState":{"shape":"WorkerConfigurationState"}
       }
     },
     "WorkerLogDelivery":{
diff --git a/models/apis/kafkaconnect/2021-09-14/docs-2.json b/models/apis/kafkaconnect/2021-09-14/docs-2.json
index ba345141973..65668e761f1 100644
--- a/models/apis/kafkaconnect/2021-09-14/docs-2.json
+++ b/models/apis/kafkaconnect/2021-09-14/docs-2.json
@@ -2,17 +2,21 @@
   "version": "2.0",
   "service": "<p/>",
   "operations": {
-    "CreateConnector": "<p>Creates a connector using the specified properties.</p>",
+    "CreateConnector": "<p>Creates a connector using the specified properties. </p>",
     "CreateCustomPlugin": "<p>Creates a custom plugin using the specified properties.</p>",
     "CreateWorkerConfiguration": "<p>Creates a worker configuration using the specified properties.</p>",
     "DeleteConnector": "<p>Deletes the specified connector.</p>",
     "DeleteCustomPlugin": "<p>Deletes a custom plugin.</p>",
+    "DeleteWorkerConfiguration": "<p>Deletes the specified worker configuration.</p>",
     "DescribeConnector": "<p>Returns summary information about the connector.</p>",
     "DescribeCustomPlugin": "<p>A summary description of the custom plugin.</p>",
     "DescribeWorkerConfiguration": "<p>Returns information about a worker configuration.</p>",
     "ListConnectors": "<p>Returns a list of all the connectors in this account and Region. The list is limited to connectors whose name starts with the specified prefix. The response also includes a description of each of the listed connectors.</p>",
     "ListCustomPlugins": "<p>Returns a list of all of the custom plugins in this account and Region.</p>",
+    "ListTagsForResource": "<p>Lists all the tags attached to the specified resource.</p>",
     "ListWorkerConfigurations": "<p>Returns a list of all of the worker configurations in this account and Region.</p>",
+    "TagResource": "<p>Attaches tags to the specified resource.</p>",
+    "UntagResource": "<p>Removes tags from the specified resource.</p>",
     "UpdateConnector": "<p>Updates the specified connector.</p>"
   },
   "shapes": {
@@ -134,7 +138,7 @@
       }
     },
     "CustomPlugin": {
-      "base": "<p>A plugin is an AWS resource that contains the code that defines a connector's logic.</p>",
+      "base": "<p>A plugin is an Amazon Web Services resource that contains the code that defines a connector's logic.</p>",
       "refs": {
         "Plugin$customPlugin": "<p>Details about a custom plugin.</p>"
       }
@@ -212,6 +216,16 @@
       "refs": {
       }
     },
+    "DeleteWorkerConfigurationRequest": {
+      "base": null,
+      "refs": {
+      }
+    },
+    "DeleteWorkerConfigurationResponse": {
+      "base": null,
+      "refs": {
+      }
+    },
     "DescribeConnectorRequest": {
       "base": null,
       "refs": {
@@ -337,6 +351,16 @@
       "refs": {
       }
     },
+    "ListTagsForResourceRequest": {
+      "base": null,
+      "refs": {
+      }
+    },
+    "ListTagsForResourceResponse": {
+      "base": null,
+      "refs": {
+      }
+    },
     "ListWorkerConfigurationsRequest": {
       "base": null,
       "refs": {
@@ -374,7 +398,7 @@
       }
     },
     "Plugin": {
-      "base": "<p>A plugin is an AWS resource that contains the code that defines your connector logic. </p>",
+      "base": "<p>A plugin is an Amazon Web Services resource that contains the code that defines your connector logic. </p>",
       "refs": {
         "__listOfPlugin$member": null
       }
@@ -475,6 +499,45 @@
         "DescribeCustomPluginResponse$stateDescription": "<p>Details about the state of a custom plugin.</p>"
       }
     },
+    "TagKey": {
+      "base": null,
+      "refs": {
+        "TagKeyList$member": null,
+        "Tags$key": null
+      }
+    },
+    "TagKeyList": {
+      "base": null,
+      "refs": {
+        "UntagResourceRequest$tagKeys": "<p>The keys of the tags that you want to remove from the resource.</p>"
+      }
+    },
+    "TagResourceRequest": {
+      "base": null,
+      "refs": {
+      }
+    },
+    "TagResourceResponse": {
+      "base": null,
+      "refs": {
+      }
+    },
+    "TagValue": {
+      "base": null,
+      "refs": {
+        "Tags$value": null
+      }
+    },
+    "Tags": {
+      "base": null,
+      "refs": {
+        "CreateConnectorRequest$tags": "<p>The tags you want to attach to the connector.</p>",
+        "CreateCustomPluginRequest$tags": "<p>The tags you want to attach to the custom plugin.</p>",
+        "CreateWorkerConfigurationRequest$tags": "<p>The tags you want to attach to the worker configuration.</p>",
+        "ListTagsForResourceResponse$tags": "<p>Lists the tags attached to the specified resource in the corresponding request.</p>",
+        "TagResourceRequest$tags": "<p>The tags that you want to attach to the resource.</p>"
+      }
+    },
     "TooManyRequestsException": {
       "base": "<p>HTTP Status Code 429: Limit exceeded. Resource limit reached.</p>",
       "refs": {
@@ -485,6 +548,16 @@
       "refs": {
       }
     },
+    "UntagResourceRequest": {
+      "base": null,
+      "refs": {
+      }
+    },
+    "UntagResourceResponse": {
+      "base": null,
+      "refs": {
+      }
+    },
     "UpdateConnectorRequest": {
       "base": null,
       "refs": {
@@ -533,6 +606,15 @@
         "WorkerConfigurationSummary$latestRevision": "<p>The latest revision of a worker configuration.</p>"
       }
     },
+    "WorkerConfigurationState": {
+      "base": null,
+      "refs": {
+        "CreateWorkerConfigurationResponse$workerConfigurationState": "<p>The state of the worker configuration.</p>",
+        "DeleteWorkerConfigurationResponse$workerConfigurationState": "<p>The state of the worker configuration.</p>",
+        "DescribeWorkerConfigurationResponse$workerConfigurationState": "<p>The state of the worker configuration.</p>",
+        "WorkerConfigurationSummary$workerConfigurationState": "<p>The state of the worker configuration.</p>"
+      }
+    },
     "WorkerConfigurationSummary": {
       "base": "<p>The summary of a worker configuration.</p>",
       "refs": {
@@ -618,7 +700,7 @@
     "__listOfPlugin": {
       "base": null,
       "refs": {
-        "CreateConnectorRequest$plugins": "<p>Specifies which plugins to use for the connector.</p>"
+        "CreateConnectorRequest$plugins": "<important> <p>Amazon MSK Connect does not currently support specifying multiple plugins as a list. To use more than one plugin for your connector, you can create a single custom plugin using a ZIP file that bundles multiple plugins together.</p> </important> <p>Specifies which plugin to use for the connector. You must specify a single-element list containing one <code>customPlugin</code> object.</p>"
       }
     },
     "__listOfPluginDescription": {
@@ -711,6 +793,8 @@
         "DeleteConnectorResponse$connectorArn": "<p>The Amazon Resource Name (ARN) of the connector that you requested to delete.</p>",
         "DeleteCustomPluginRequest$customPluginArn": "<p>The Amazon Resource Name (ARN) of the custom plugin that you want to delete.</p>",
         "DeleteCustomPluginResponse$customPluginArn": "<p>The Amazon Resource Name (ARN) of the custom plugin that you requested to delete.</p>",
+        "DeleteWorkerConfigurationRequest$workerConfigurationArn": "<p>The Amazon Resource Name (ARN) of the worker configuration that you want to delete.</p>",
+        "DeleteWorkerConfigurationResponse$workerConfigurationArn": "<p>The Amazon Resource Name (ARN) of the worker configuration that you requested to delete.</p>",
         "DescribeConnectorRequest$connectorArn": "<p>The Amazon Resource Name (ARN) of the connector that you want to describe.</p>",
         "DescribeConnectorResponse$connectorArn": "<p>The Amazon Resource Name (ARN) of the connector.</p>",
         "DescribeConnectorResponse$connectorDescription": "<p>A summary description of the connector.</p>",
@@ -733,8 +817,11 @@
         "ListConnectorsRequest$connectorNamePrefix": "<p>The name prefix that you want to use to search for and list connectors.</p>",
         "ListConnectorsRequest$nextToken": "<p>If the response of a ListConnectors operation is truncated, it will include a NextToken. Send this NextToken in a subsequent request to continue listing from where the previous operation left off.</p>",
         "ListConnectorsResponse$nextToken": "<p>If the response of a ListConnectors operation is truncated, it will include a NextToken. Send this NextToken in a subsequent request to continue listing from where it left off.</p>",
+        "ListCustomPluginsRequest$namePrefix": "<p>Lists custom plugin names that start with the specified text string.</p>",
         "ListCustomPluginsRequest$nextToken": "<p>If the response of a ListCustomPlugins operation is truncated, it will include a NextToken. Send this NextToken in a subsequent request to continue listing from where the previous operation left off.</p>",
         "ListCustomPluginsResponse$nextToken": "<p>If the response of a ListCustomPlugins operation is truncated, it will include a NextToken. Send this NextToken in a subsequent request to continue listing from where the previous operation left off.</p>",
+        "ListTagsForResourceRequest$resourceArn": "<p>The Amazon Resource Name (ARN) of the resource for which you want to list all attached tags.</p>",
+        "ListWorkerConfigurationsRequest$namePrefix": "<p>Lists worker configuration names that start with the specified text string.</p>",
         "ListWorkerConfigurationsRequest$nextToken": "<p>If the response of a ListWorkerConfigurations operation is truncated, it will include a NextToken. Send this NextToken in a subsequent request to continue listing from where the previous operation left off.</p>",
         "ListWorkerConfigurationsResponse$nextToken": "<p>If the response of a ListWorkerConfigurations operation is truncated, it will include a NextToken. Send this NextToken in a subsequent request to continue listing from where the previous operation left off.</p>",
         "NotFoundException$message": null,
@@ -751,8 +838,10 @@
         "ServiceUnavailableException$message": null,
         "StateDescription$code": "<p>A code that describes the state of a resource.</p>",
         "StateDescription$message": "<p>A message that describes the state of a resource.</p>",
+        "TagResourceRequest$resourceArn": "<p>The Amazon Resource Name (ARN) of the resource to which you want to attach tags.</p>",
         "TooManyRequestsException$message": null,
         "UnauthorizedException$message": null,
+        "UntagResourceRequest$resourceArn": "<p>The Amazon Resource Name (ARN) of the resource from which you want to remove tags.</p>",
         "UpdateConnectorRequest$connectorArn": "<p>The Amazon Resource Name (ARN) of the connector that you want to update.</p>",
         "UpdateConnectorRequest$currentVersion": "<p>The current version of the connector that you want to update.</p>",
         "UpdateConnectorResponse$connectorArn": "<p>The Amazon Resource Name (ARN) of the connector.</p>",
diff --git a/models/apis/kafkaconnect/2021-09-14/endpoint-rule-set-1.json b/models/apis/kafkaconnect/2021-09-14/endpoint-rule-set-1.json
index c5b90d3def0..545020b141c 100644
--- a/models/apis/kafkaconnect/2021-09-14/endpoint-rule-set-1.json
+++ b/models/apis/kafkaconnect/2021-09-14/endpoint-rule-set-1.json
@@ -40,7 +40,6 @@
                     ]
                 }
             ],
-            "type": "tree",
             "rules": [
                 {
                     "conditions": [
@@ -83,7 +82,8 @@
                     },
                     "type": "endpoint"
                 }
-            ]
+            ],
+            "type": "tree"
         },
         {
             "conditions": [
@@ -96,7 +96,6 @@
                     ]
                 }
             ],
-            "type": "tree",
             "rules": [
                 {
                     "conditions": [
@@ -110,7 +109,6 @@
                             "assign": "PartitionResult"
                         }
                     ],
-                    "type": "tree",
                     "rules": [
                         {
                             "conditions": [
@@ -133,7 +131,6 @@
                                     ]
                                 }
                             ],
-                            "type": "tree",
                             "rules": [
                                 {
                                     "conditions": [
@@ -168,7 +165,6 @@
                                             ]
                                         }
                                     ],
-                                    "type": "tree",
                                     "rules": [
                                         {
                                             "conditions": [],
@@ -179,14 +175,16 @@
                                             },
                                             "type": "endpoint"
                                         }
-                                    ]
+                                    ],
+                                    "type": "tree"
                                 },
                                 {
                                     "conditions": [],
                                     "error": "FIPS and DualStack are enabled, but this partition does not support one or both",
                                     "type": "error"
                                 }
-                            ]
+                            ],
+                            "type": "tree"
                         },
                         {
                             "conditions": [
@@ -200,14 +198,12 @@
                                     ]
                                 }
                             ],
-                            "type": "tree",
                             "rules": [
                                 {
                                     "conditions": [
                                         {
                                             "fn": "booleanEquals",
                                             "argv": [
-                                                true,
                                                 {
                                                     "fn": "getAttr",
                                                     "argv": [
@@ -216,11 +212,11 @@
                                                         },
                                                         "supportsFIPS"
                                                     ]
-                                                }
+                                                },
+                                                true
                                             ]
                                         }
                                     ],
-                                    "type": "tree",
                                     "rules": [
                                         {
                                             "conditions": [],
@@ -231,14 +227,16 @@
                                             },
                                             "type": "endpoint"
                                         }
-                                    ]
+                                    ],
+                                    "type": "tree"
                                 },
                                 {
                                     "conditions": [],
                                     "error": "FIPS is enabled but this partition does not support FIPS",
                                     "type": "error"
                                 }
-                            ]
+                            ],
+                            "type": "tree"
                         },
                         {
                             "conditions": [
@@ -252,7 +250,6 @@
                                     ]
                                 }
                             ],
-                            "type": "tree",
                             "rules": [
                                 {
                                     "conditions": [
@@ -272,7 +269,6 @@
                                             ]
                                         }
                                     ],
-                                    "type": "tree",
                                     "rules": [
                                         {
                                             "conditions": [],
@@ -283,14 +279,16 @@
                                             },
                                             "type": "endpoint"
                                         }
-                                    ]
+                                    ],
+                                    "type": "tree"
                                 },
                                 {
                                     "conditions": [],
                                     "error": "DualStack is enabled but this partition does not support DualStack",
                                     "type": "error"
                                 }
-                            ]
+                            ],
+                            "type": "tree"
                         },
                         {
                             "conditions": [],
@@ -301,9 +299,11 @@
                             },
                             "type": "endpoint"
                         }
-                    ]
+                    ],
+                    "type": "tree"
                 }
-            ]
+            ],
+            "type": "tree"
         },
         {
             "conditions": [],
diff --git a/models/apis/rds/2014-10-31/api-2.json b/models/apis/rds/2014-10-31/api-2.json
index 3755b4ad451..f28d4dc8881 100644
--- a/models/apis/rds/2014-10-31/api-2.json
+++ b/models/apis/rds/2014-10-31/api-2.json
@@ -4147,7 +4147,8 @@
         "IOOptimizedNextAllowedModificationTime":{"shape":"TStamp"},
         "LocalWriteForwardingStatus":{"shape":"LocalWriteForwardingStatus"},
         "AwsBackupRecoveryPointArn":{"shape":"String"},
-        "LimitlessDatabase":{"shape":"LimitlessDatabase"}
+        "LimitlessDatabase":{"shape":"LimitlessDatabase"},
+        "StorageThroughput":{"shape":"IntegerOptional"}
       },
       "wrapper":true
     },
@@ -4188,7 +4189,8 @@
         "KmsKeyId":{"shape":"String"},
         "StorageType":{"shape":"String"},
         "Iops":{"shape":"IntegerOptional"},
-        "AwsBackupRecoveryPointArn":{"shape":"String"}
+        "AwsBackupRecoveryPointArn":{"shape":"String"},
+        "StorageThroughput":{"shape":"IntegerOptional"}
       },
       "wrapper":true
     },
@@ -4532,7 +4534,8 @@
         "TagList":{"shape":"TagList"},
         "DBSystemId":{"shape":"String"},
         "StorageType":{"shape":"String"},
-        "DbClusterResourceId":{"shape":"String"}
+        "DbClusterResourceId":{"shape":"String"},
+        "StorageThroughput":{"shape":"IntegerOptional"}
       },
       "wrapper":true
     },
diff --git a/models/apis/rds/2014-10-31/docs-2.json b/models/apis/rds/2014-10-31/docs-2.json
index e0570d41b75..a9e7b65dcb6 100644
--- a/models/apis/rds/2014-10-31/docs-2.json
+++ b/models/apis/rds/2014-10-31/docs-2.json
@@ -3012,12 +3012,15 @@
         "DBCluster$Iops": "<p>The Provisioned IOPS (I/O operations per second) value.</p> <p>This setting is only for non-Aurora Multi-AZ DB clusters.</p>",
         "DBCluster$MonitoringInterval": "<p>The interval, in seconds, between points when Enhanced Monitoring metrics are collected for the DB cluster.</p> <p>This setting is only for non-Aurora Multi-AZ DB clusters.</p>",
         "DBCluster$PerformanceInsightsRetentionPeriod": "<p>The number of days to retain Performance Insights data.</p> <p>This setting is only for non-Aurora Multi-AZ DB clusters.</p> <p>Valid Values:</p> <ul> <li> <p> <code>7</code> </p> </li> <li> <p> <i>month</i> * 31, where <i>month</i> is a number of months from 1-23. Examples: <code>93</code> (3 months * 31), <code>341</code> (11 months * 31), <code>589</code> (19 months * 31)</p> </li> <li> <p> <code>731</code> </p> </li> </ul> <p>Default: <code>7</code> days</p>",
+        "DBCluster$StorageThroughput": "<p>The storage throughput for the DB cluster. The throughput is automatically set based on the IOPS that you provision, and is not configurable.</p> <p>This setting is only for non-Aurora Multi-AZ DB clusters.</p>",
         "DBClusterAutomatedBackup$BackupRetentionPeriod": "<p>The retention period for the automated backups.</p>",
         "DBClusterAutomatedBackup$Iops": "<p>The IOPS (I/O operations per second) value for the automated backup.</p> <p>This setting is only for non-Aurora Multi-AZ DB clusters.</p>",
+        "DBClusterAutomatedBackup$StorageThroughput": "<p>The storage throughput for the automated backup. The throughput is automatically set based on the IOPS that you provision, and is not configurable.</p> <p>This setting is only for non-Aurora Multi-AZ DB clusters.</p>",
         "DBClusterCapacityInfo$PendingCapacity": "<p>A value that specifies the capacity that the DB cluster scales to next.</p>",
         "DBClusterCapacityInfo$CurrentCapacity": "<p>The current capacity of the DB cluster.</p>",
         "DBClusterCapacityInfo$SecondsBeforeTimeout": "<p>The number of seconds before a call to <code>ModifyCurrentDBClusterCapacity</code> times out.</p>",
         "DBClusterMember$PromotionTier": "<p>A value that specifies the order in which an Aurora Replica is promoted to the primary instance after a failure of the existing primary instance. For more information, see <a href=\"https://docs.aws.amazon.com/AmazonRDS/latest/AuroraUserGuide/Aurora.Managing.Backups.html#Aurora.Managing.FaultTolerance\"> Fault Tolerance for an Aurora DB Cluster</a> in the <i>Amazon Aurora User Guide</i>.</p>",
+        "DBClusterSnapshot$StorageThroughput": "<p>The storage throughput for the DB cluster snapshot. The throughput is automatically set based on the IOPS that you provision, and is not configurable.</p> <p>This setting is only for non-Aurora Multi-AZ DB clusters.</p>",
         "DBInstance$Iops": "<p>The Provisioned IOPS (I/O operations per second) value for the DB instance.</p>",
         "DBInstance$MonitoringInterval": "<p>The interval, in seconds, between points when Enhanced Monitoring metrics are collected for the DB instance.</p>",
         "DBInstance$PromotionTier": "<p>The order of priority in which an Aurora Replica is promoted to the primary instance after a failure of the existing primary instance. For more information, see <a href=\"https://docs.aws.amazon.com/AmazonRDS/latest/AuroraUserGuide/Concepts.AuroraHighAvailability.html#Aurora.Managing.FaultTolerance\"> Fault Tolerance for an Aurora DB Cluster</a> in the <i>Amazon Aurora User Guide</i>.</p>",
@@ -5553,7 +5556,7 @@
         "RestoreDBInstanceFromDBSnapshotMessage$CustomIamInstanceProfile": "<p>The instance profile associated with the underlying Amazon EC2 instance of an RDS Custom DB instance. The instance profile must meet the following requirements:</p> <ul> <li> <p>The profile must exist in your account.</p> </li> <li> <p>The profile must have an IAM role that Amazon EC2 has permissions to assume.</p> </li> <li> <p>The instance profile name and the associated IAM role name must start with the prefix <code>AWSRDSCustom</code>.</p> </li> </ul> <p>For the list of permissions required for the IAM role, see <a href=\"https://docs.aws.amazon.com/AmazonRDS/latest/UserGuide/custom-setup-orcl.html#custom-setup-orcl.iam-vpc\"> Configure IAM and your VPC</a> in the <i>Amazon RDS User Guide</i>.</p> <p>This setting is required for RDS Custom.</p>",
         "RestoreDBInstanceFromDBSnapshotMessage$BackupTarget": "<p>Specifies where automated backups and manual snapshots are stored for the restored DB instance.</p> <p>Possible values are <code>outposts</code> (Amazon Web Services Outposts) and <code>region</code> (Amazon Web Services Region). The default is <code>region</code>.</p> <p>For more information, see <a href=\"https://docs.aws.amazon.com/AmazonRDS/latest/UserGuide/rds-on-outposts.html\">Working with Amazon RDS on Amazon Web Services Outposts</a> in the <i>Amazon RDS User Guide</i>.</p>",
         "RestoreDBInstanceFromDBSnapshotMessage$NetworkType": "<p>The network type of the DB instance.</p> <p>Valid Values:</p> <ul> <li> <p> <code>IPV4</code> </p> </li> <li> <p> <code>DUAL</code> </p> </li> </ul> <p>The network type is determined by the <code>DBSubnetGroup</code> specified for the DB instance. A <code>DBSubnetGroup</code> can support only the IPv4 protocol or the IPv4 and the IPv6 protocols (<code>DUAL</code>).</p> <p>For more information, see <a href=\"https://docs.aws.amazon.com/AmazonRDS/latest/UserGuide/USER_VPC.WorkingWithRDSInstanceinaVPC.html\"> Working with a DB instance in a VPC</a> in the <i>Amazon RDS User Guide.</i> </p>",
-        "RestoreDBInstanceFromDBSnapshotMessage$DBClusterSnapshotIdentifier": "<p>The identifier for the RDS for MySQL Multi-AZ DB cluster snapshot to restore from.</p> <p>For more information on Multi-AZ DB clusters, see <a href=\"https://docs.aws.amazon.com/AmazonRDS/latest/UserGuide/multi-az-db-clusters-concepts.html\"> Multi-AZ DB cluster deployments</a> in the <i>Amazon RDS User Guide</i>.</p> <p>Constraints:</p> <ul> <li> <p>Must match the identifier of an existing Multi-AZ DB cluster snapshot.</p> </li> <li> <p>Can't be specified when <code>DBSnapshotIdentifier</code> is specified.</p> </li> <li> <p>Must be specified when <code>DBSnapshotIdentifier</code> isn't specified.</p> </li> <li> <p>If you are restoring from a shared manual Multi-AZ DB cluster snapshot, the <code>DBClusterSnapshotIdentifier</code> must be the ARN of the shared snapshot.</p> </li> <li> <p>Can't be the identifier of an Aurora DB cluster snapshot.</p> </li> <li> <p>Can't be the identifier of an RDS for PostgreSQL Multi-AZ DB cluster snapshot.</p> </li> </ul>",
+        "RestoreDBInstanceFromDBSnapshotMessage$DBClusterSnapshotIdentifier": "<p>The identifier for the Multi-AZ DB cluster snapshot to restore from.</p> <p>For more information on Multi-AZ DB clusters, see <a href=\"https://docs.aws.amazon.com/AmazonRDS/latest/UserGuide/multi-az-db-clusters-concepts.html\"> Multi-AZ DB cluster deployments</a> in the <i>Amazon RDS User Guide</i>.</p> <p>Constraints:</p> <ul> <li> <p>Must match the identifier of an existing Multi-AZ DB cluster snapshot.</p> </li> <li> <p>Can't be specified when <code>DBSnapshotIdentifier</code> is specified.</p> </li> <li> <p>Must be specified when <code>DBSnapshotIdentifier</code> isn't specified.</p> </li> <li> <p>If you are restoring from a shared manual Multi-AZ DB cluster snapshot, the <code>DBClusterSnapshotIdentifier</code> must be the ARN of the shared snapshot.</p> </li> <li> <p>Can't be the identifier of an Aurora DB cluster snapshot.</p> </li> </ul>",
         "RestoreDBInstanceFromS3Message$DBName": "<p>The name of the database to create when the DB instance is created. Follow the naming rules specified in <code>CreateDBInstance</code>.</p>",
         "RestoreDBInstanceFromS3Message$DBInstanceIdentifier": "<p>The DB instance identifier. This parameter is stored as a lowercase string.</p> <p>Constraints:</p> <ul> <li> <p>Must contain from 1 to 63 letters, numbers, or hyphens.</p> </li> <li> <p>First character must be a letter.</p> </li> <li> <p>Can't end with a hyphen or contain two consecutive hyphens.</p> </li> </ul> <p>Example: <code>mydbinstance</code> </p>",
         "RestoreDBInstanceFromS3Message$DBInstanceClass": "<p>The compute and memory capacity of the DB instance, for example db.m4.large. Not all DB instance classes are available in all Amazon Web Services Regions, or for all database engines. For the full list of DB instance classes, and availability for your engine, see <a href=\"https://docs.aws.amazon.com/AmazonRDS/latest/UserGuide/Concepts.DBInstanceClass.html\">DB Instance Class</a> in the <i>Amazon RDS User Guide.</i> </p> <p>Importing from Amazon S3 isn't supported on the db.t2.micro DB instance class.</p>",
diff --git a/service/apigateway/api.go b/service/apigateway/api.go
index 2cf3cc07916..5a83e95b66c 100644
--- a/service/apigateway/api.go
+++ b/service/apigateway/api.go
@@ -10817,7 +10817,7 @@ func (c *APIGateway) UpdateModelRequest(input *UpdateModelInput) (req *request.R
 
 // UpdateModel API operation for Amazon API Gateway.
 //
-// Changes information about a model.
+// Changes information about a model. The maximum size of the model is 400 KB.
 //
 // Returns awserr.Error for service API and SDK errors. Use runtime type assertions
 // with awserr.Error's Code and Message methods to get detailed information about
@@ -13133,7 +13133,7 @@ type CreateModelInput struct {
 	RestApiId *string `location:"uri" locationName:"restapi_id" type:"string" required:"true"`
 
 	// The schema for the model. For application/json models, this should be JSON
-	// schema draft 4 model.
+	// schema draft 4 model. The maximum size of the model is 400 KB.
 	Schema *string `locationName:"schema" type:"string"`
 }
 
@@ -23479,7 +23479,8 @@ type Stage struct {
 	// Settings for logging access in this stage.
 	AccessLogSettings *AccessLogSettings `locationName:"accessLogSettings" type:"structure"`
 
-	// Specifies whether a cache cluster is enabled for the stage.
+	// Specifies whether a cache cluster is enabled for the stage. To activate a
+	// method-level cache, set CachingEnabled to true for a method.
 	CacheClusterEnabled *bool `locationName:"cacheClusterEnabled" type:"boolean"`
 
 	// The stage's cache capacity in GB. For more information about choosing a cache
diff --git a/service/drs/api.go b/service/drs/api.go
index 0ccf0ad9804..488e459cd26 100644
--- a/service/drs/api.go
+++ b/service/drs/api.go
@@ -5713,6 +5713,10 @@ type ConversionProperties struct {
 	// ids
 	VolumeToConversionMap map[string]map[string]*string `locationName:"volumeToConversionMap" type:"map"`
 
+	// A mapping between the volumes being converted and the product codes associated
+	// with them
+	VolumeToProductCodes map[string][]*ProductCode `locationName:"volumeToProductCodes" type:"map"`
+
 	// A mapping between the volumes and their sizes
 	VolumeToVolumeSize map[string]*int64 `locationName:"volumeToVolumeSize" type:"map"`
 }
@@ -5759,6 +5763,12 @@ func (s *ConversionProperties) SetVolumeToConversionMap(v map[string]map[string]
 	return s
 }
 
+// SetVolumeToProductCodes sets the VolumeToProductCodes field's value.
+func (s *ConversionProperties) SetVolumeToProductCodes(v map[string][]*ProductCode) *ConversionProperties {
+	s.VolumeToProductCodes = v
+	return s
+}
+
 // SetVolumeToVolumeSize sets the VolumeToVolumeSize field's value.
 func (s *ConversionProperties) SetVolumeToVolumeSize(v map[string]*int64) *ConversionProperties {
 	s.VolumeToVolumeSize = v
@@ -6729,6 +6739,9 @@ type DataReplicationInfoReplicatedDisk struct {
 
 	// The total amount of data to be replicated in bytes.
 	TotalStorageBytes *int64 `locationName:"totalStorageBytes" type:"long"`
+
+	// The status of the volume.
+	VolumeStatus *string `locationName:"volumeStatus" type:"string" enum:"VolumeStatus"`
 }
 
 // String returns the string representation.
@@ -6779,6 +6792,12 @@ func (s *DataReplicationInfoReplicatedDisk) SetTotalStorageBytes(v int64) *DataR
 	return s
 }
 
+// SetVolumeStatus sets the VolumeStatus field's value.
+func (s *DataReplicationInfoReplicatedDisk) SetVolumeStatus(v string) *DataReplicationInfoReplicatedDisk {
+	s.VolumeStatus = &v
+	return s
+}
+
 // Data replication initiation.
 type DataReplicationInitiation struct {
 	_ struct{} `type:"structure"`
@@ -11266,6 +11285,47 @@ func (s *ParticipatingServer) SetSourceServerID(v string) *ParticipatingServer {
 	return s
 }
 
+// Properties of a product code associated with a volume.
+type ProductCode struct {
+	_ struct{} `type:"structure"`
+
+	// Id of a product code associated with a volume.
+	ProductCodeId *string `locationName:"productCodeId" min:"25" type:"string"`
+
+	// Mode of a product code associated with a volume.
+	ProductCodeMode *string `locationName:"productCodeMode" type:"string" enum:"ProductCodeMode"`
+}
+
+// String returns the string representation.
+//
+// API parameter values that are decorated as "sensitive" in the API will not
+// be included in the string output. The member name will be present, but the
+// value will be replaced with "sensitive".
+func (s ProductCode) String() string {
+	return awsutil.Prettify(s)
+}
+
+// GoString returns the string representation.
+//
+// API parameter values that are decorated as "sensitive" in the API will not
+// be included in the string output. The member name will be present, but the
+// value will be replaced with "sensitive".
+func (s ProductCode) GoString() string {
+	return s.String()
+}
+
+// SetProductCodeId sets the ProductCodeId field's value.
+func (s *ProductCode) SetProductCodeId(v string) *ProductCode {
+	s.ProductCodeId = &v
+	return s
+}
+
+// SetProductCodeMode sets the ProductCodeMode field's value.
+func (s *ProductCode) SetProductCodeMode(v string) *ProductCode {
+	s.ProductCodeMode = &v
+	return s
+}
+
 type PutLaunchActionInput struct {
 	_ struct{} `type:"structure"`
 
@@ -17195,6 +17255,22 @@ func PITPolicyRuleUnits_Values() []string {
 	}
 }
 
+const (
+	// ProductCodeModeEnabled is a ProductCodeMode enum value
+	ProductCodeModeEnabled = "ENABLED"
+
+	// ProductCodeModeDisabled is a ProductCodeMode enum value
+	ProductCodeModeDisabled = "DISABLED"
+)
+
+// ProductCodeMode_Values returns all elements of the ProductCodeMode enum
+func ProductCodeMode_Values() []string {
+	return []string{
+		ProductCodeModeEnabled,
+		ProductCodeModeDisabled,
+	}
+}
+
 const (
 	// RecoveryInstanceDataReplicationInitiationStepNameLinkFailbackClientWithRecoveryInstance is a RecoveryInstanceDataReplicationInitiationStepName enum value
 	RecoveryInstanceDataReplicationInitiationStepNameLinkFailbackClientWithRecoveryInstance = "LINK_FAILBACK_CLIENT_WITH_RECOVERY_INSTANCE"
@@ -17596,3 +17672,27 @@ func ValidationExceptionReason_Values() []string {
 		ValidationExceptionReasonOther,
 	}
 }
+
+const (
+	// VolumeStatusRegular is a VolumeStatus enum value
+	VolumeStatusRegular = "REGULAR"
+
+	// VolumeStatusContainsMarketplaceProductCodes is a VolumeStatus enum value
+	VolumeStatusContainsMarketplaceProductCodes = "CONTAINS_MARKETPLACE_PRODUCT_CODES"
+
+	// VolumeStatusMissingVolumeAttributes is a VolumeStatus enum value
+	VolumeStatusMissingVolumeAttributes = "MISSING_VOLUME_ATTRIBUTES"
+
+	// VolumeStatusMissingVolumeAttributesAndPrecheckUnavailable is a VolumeStatus enum value
+	VolumeStatusMissingVolumeAttributesAndPrecheckUnavailable = "MISSING_VOLUME_ATTRIBUTES_AND_PRECHECK_UNAVAILABLE"
+)
+
+// VolumeStatus_Values returns all elements of the VolumeStatus enum
+func VolumeStatus_Values() []string {
+	return []string{
+		VolumeStatusRegular,
+		VolumeStatusContainsMarketplaceProductCodes,
+		VolumeStatusMissingVolumeAttributes,
+		VolumeStatusMissingVolumeAttributesAndPrecheckUnavailable,
+	}
+}
diff --git a/service/kafkaconnect/api.go b/service/kafkaconnect/api.go
index fa8aae783d9..52490377ac8 100644
--- a/service/kafkaconnect/api.go
+++ b/service/kafkaconnect/api.go
@@ -10,6 +10,7 @@ import (
 	"github.com/aws/aws-sdk-go/aws/awsutil"
 	"github.com/aws/aws-sdk-go/aws/request"
 	"github.com/aws/aws-sdk-go/private/protocol"
+	"github.com/aws/aws-sdk-go/private/protocol/restjson"
 )
 
 const opCreateConnector = "CreateConnector"
@@ -539,6 +540,109 @@ func (c *KafkaConnect) DeleteCustomPluginWithContext(ctx aws.Context, input *Del
 	return out, req.Send()
 }
 
+const opDeleteWorkerConfiguration = "DeleteWorkerConfiguration"
+
+// DeleteWorkerConfigurationRequest generates a "aws/request.Request" representing the
+// client's request for the DeleteWorkerConfiguration operation. The "output" return
+// value will be populated with the request's response once the request completes
+// successfully.
+//
+// Use "Send" method on the returned Request to send the API call to the service.
+// the "output" return value is not valid until after Send returns without error.
+//
+// See DeleteWorkerConfiguration for more information on using the DeleteWorkerConfiguration
+// API call, and error handling.
+//
+// This method is useful when you want to inject custom logic or configuration
+// into the SDK's request lifecycle. Such as custom headers, or retry logic.
+//
+//	// Example sending a request using the DeleteWorkerConfigurationRequest method.
+//	req, resp := client.DeleteWorkerConfigurationRequest(params)
+//
+//	err := req.Send()
+//	if err == nil { // resp is now filled
+//	    fmt.Println(resp)
+//	}
+//
+// See also, https://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/DeleteWorkerConfiguration
+func (c *KafkaConnect) DeleteWorkerConfigurationRequest(input *DeleteWorkerConfigurationInput) (req *request.Request, output *DeleteWorkerConfigurationOutput) {
+	op := &request.Operation{
+		Name:       opDeleteWorkerConfiguration,
+		HTTPMethod: "DELETE",
+		HTTPPath:   "/v1/worker-configurations/{workerConfigurationArn}",
+	}
+
+	if input == nil {
+		input = &DeleteWorkerConfigurationInput{}
+	}
+
+	output = &DeleteWorkerConfigurationOutput{}
+	req = c.newRequest(op, input, output)
+	return
+}
+
+// DeleteWorkerConfiguration API operation for Managed Streaming for Kafka Connect.
+//
+// Deletes the specified worker configuration.
+//
+// Returns awserr.Error for service API and SDK errors. Use runtime type assertions
+// with awserr.Error's Code and Message methods to get detailed information about
+// the error.
+//
+// See the AWS API reference guide for Managed Streaming for Kafka Connect's
+// API operation DeleteWorkerConfiguration for usage and error information.
+//
+// Returned Error Types:
+//
+//   - NotFoundException
+//     HTTP Status Code 404: Resource not found due to incorrect input. Correct
+//     your request and then retry it.
+//
+//   - BadRequestException
+//     HTTP Status Code 400: Bad request due to incorrect input. Correct your request
+//     and then retry it.
+//
+//   - ForbiddenException
+//     HTTP Status Code 403: Access forbidden. Correct your credentials and then
+//     retry your request.
+//
+//   - ServiceUnavailableException
+//     HTTP Status Code 503: Service Unavailable. Retrying your request in some
+//     time might resolve the issue.
+//
+//   - TooManyRequestsException
+//     HTTP Status Code 429: Limit exceeded. Resource limit reached.
+//
+//   - UnauthorizedException
+//     HTTP Status Code 401: Unauthorized request. The provided credentials couldn't
+//     be validated.
+//
+//   - InternalServerErrorException
+//     HTTP Status Code 500: Unexpected internal server error. Retrying your request
+//     might resolve the issue.
+//
+// See also, https://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/DeleteWorkerConfiguration
+func (c *KafkaConnect) DeleteWorkerConfiguration(input *DeleteWorkerConfigurationInput) (*DeleteWorkerConfigurationOutput, error) {
+	req, out := c.DeleteWorkerConfigurationRequest(input)
+	return out, req.Send()
+}
+
+// DeleteWorkerConfigurationWithContext is the same as DeleteWorkerConfiguration with the addition of
+// the ability to pass a context and additional request options.
+//
+// See DeleteWorkerConfiguration for details on how to use this API operation.
+//
+// The context must be non-nil and will be used for request cancellation. If
+// the context is nil a panic will occur. In the future the SDK may create
+// sub-contexts for http.Requests. See https://golang.org/pkg/context/
+// for more information on using Contexts.
+func (c *KafkaConnect) DeleteWorkerConfigurationWithContext(ctx aws.Context, input *DeleteWorkerConfigurationInput, opts ...request.Option) (*DeleteWorkerConfigurationOutput, error) {
+	req, out := c.DeleteWorkerConfigurationRequest(input)
+	req.SetContext(ctx)
+	req.ApplyOptions(opts...)
+	return out, req.Send()
+}
+
 const opDescribeConnector = "DescribeConnector"
 
 // DescribeConnectorRequest generates a "aws/request.Request" representing the
@@ -1170,6 +1274,109 @@ func (c *KafkaConnect) ListCustomPluginsPagesWithContext(ctx aws.Context, input
 	return p.Err()
 }
 
+const opListTagsForResource = "ListTagsForResource"
+
+// ListTagsForResourceRequest generates a "aws/request.Request" representing the
+// client's request for the ListTagsForResource operation. The "output" return
+// value will be populated with the request's response once the request completes
+// successfully.
+//
+// Use "Send" method on the returned Request to send the API call to the service.
+// the "output" return value is not valid until after Send returns without error.
+//
+// See ListTagsForResource for more information on using the ListTagsForResource
+// API call, and error handling.
+//
+// This method is useful when you want to inject custom logic or configuration
+// into the SDK's request lifecycle. Such as custom headers, or retry logic.
+//
+//	// Example sending a request using the ListTagsForResourceRequest method.
+//	req, resp := client.ListTagsForResourceRequest(params)
+//
+//	err := req.Send()
+//	if err == nil { // resp is now filled
+//	    fmt.Println(resp)
+//	}
+//
+// See also, https://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/ListTagsForResource
+func (c *KafkaConnect) ListTagsForResourceRequest(input *ListTagsForResourceInput) (req *request.Request, output *ListTagsForResourceOutput) {
+	op := &request.Operation{
+		Name:       opListTagsForResource,
+		HTTPMethod: "GET",
+		HTTPPath:   "/v1/tags/{resourceArn}",
+	}
+
+	if input == nil {
+		input = &ListTagsForResourceInput{}
+	}
+
+	output = &ListTagsForResourceOutput{}
+	req = c.newRequest(op, input, output)
+	return
+}
+
+// ListTagsForResource API operation for Managed Streaming for Kafka Connect.
+//
+// Lists all the tags attached to the specified resource.
+//
+// Returns awserr.Error for service API and SDK errors. Use runtime type assertions
+// with awserr.Error's Code and Message methods to get detailed information about
+// the error.
+//
+// See the AWS API reference guide for Managed Streaming for Kafka Connect's
+// API operation ListTagsForResource for usage and error information.
+//
+// Returned Error Types:
+//
+//   - NotFoundException
+//     HTTP Status Code 404: Resource not found due to incorrect input. Correct
+//     your request and then retry it.
+//
+//   - BadRequestException
+//     HTTP Status Code 400: Bad request due to incorrect input. Correct your request
+//     and then retry it.
+//
+//   - ForbiddenException
+//     HTTP Status Code 403: Access forbidden. Correct your credentials and then
+//     retry your request.
+//
+//   - ServiceUnavailableException
+//     HTTP Status Code 503: Service Unavailable. Retrying your request in some
+//     time might resolve the issue.
+//
+//   - TooManyRequestsException
+//     HTTP Status Code 429: Limit exceeded. Resource limit reached.
+//
+//   - UnauthorizedException
+//     HTTP Status Code 401: Unauthorized request. The provided credentials couldn't
+//     be validated.
+//
+//   - InternalServerErrorException
+//     HTTP Status Code 500: Unexpected internal server error. Retrying your request
+//     might resolve the issue.
+//
+// See also, https://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/ListTagsForResource
+func (c *KafkaConnect) ListTagsForResource(input *ListTagsForResourceInput) (*ListTagsForResourceOutput, error) {
+	req, out := c.ListTagsForResourceRequest(input)
+	return out, req.Send()
+}
+
+// ListTagsForResourceWithContext is the same as ListTagsForResource with the addition of
+// the ability to pass a context and additional request options.
+//
+// See ListTagsForResource for details on how to use this API operation.
+//
+// The context must be non-nil and will be used for request cancellation. If
+// the context is nil a panic will occur. In the future the SDK may create
+// sub-contexts for http.Requests. See https://golang.org/pkg/context/
+// for more information on using Contexts.
+func (c *KafkaConnect) ListTagsForResourceWithContext(ctx aws.Context, input *ListTagsForResourceInput, opts ...request.Option) (*ListTagsForResourceOutput, error) {
+	req, out := c.ListTagsForResourceRequest(input)
+	req.SetContext(ctx)
+	req.ApplyOptions(opts...)
+	return out, req.Send()
+}
+
 const opListWorkerConfigurations = "ListWorkerConfigurations"
 
 // ListWorkerConfigurationsRequest generates a "aws/request.Request" representing the
@@ -1330,6 +1537,218 @@ func (c *KafkaConnect) ListWorkerConfigurationsPagesWithContext(ctx aws.Context,
 	return p.Err()
 }
 
+const opTagResource = "TagResource"
+
+// TagResourceRequest generates a "aws/request.Request" representing the
+// client's request for the TagResource operation. The "output" return
+// value will be populated with the request's response once the request completes
+// successfully.
+//
+// Use "Send" method on the returned Request to send the API call to the service.
+// the "output" return value is not valid until after Send returns without error.
+//
+// See TagResource for more information on using the TagResource
+// API call, and error handling.
+//
+// This method is useful when you want to inject custom logic or configuration
+// into the SDK's request lifecycle. Such as custom headers, or retry logic.
+//
+//	// Example sending a request using the TagResourceRequest method.
+//	req, resp := client.TagResourceRequest(params)
+//
+//	err := req.Send()
+//	if err == nil { // resp is now filled
+//	    fmt.Println(resp)
+//	}
+//
+// See also, https://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/TagResource
+func (c *KafkaConnect) TagResourceRequest(input *TagResourceInput) (req *request.Request, output *TagResourceOutput) {
+	op := &request.Operation{
+		Name:       opTagResource,
+		HTTPMethod: "POST",
+		HTTPPath:   "/v1/tags/{resourceArn}",
+	}
+
+	if input == nil {
+		input = &TagResourceInput{}
+	}
+
+	output = &TagResourceOutput{}
+	req = c.newRequest(op, input, output)
+	req.Handlers.Unmarshal.Swap(restjson.UnmarshalHandler.Name, protocol.UnmarshalDiscardBodyHandler)
+	return
+}
+
+// TagResource API operation for Managed Streaming for Kafka Connect.
+//
+// Attaches tags to the specified resource.
+//
+// Returns awserr.Error for service API and SDK errors. Use runtime type assertions
+// with awserr.Error's Code and Message methods to get detailed information about
+// the error.
+//
+// See the AWS API reference guide for Managed Streaming for Kafka Connect's
+// API operation TagResource for usage and error information.
+//
+// Returned Error Types:
+//
+//   - NotFoundException
+//     HTTP Status Code 404: Resource not found due to incorrect input. Correct
+//     your request and then retry it.
+//
+//   - ConflictException
+//     HTTP Status Code 409: Conflict. A resource with this name already exists.
+//     Retry your request with another name.
+//
+//   - BadRequestException
+//     HTTP Status Code 400: Bad request due to incorrect input. Correct your request
+//     and then retry it.
+//
+//   - ForbiddenException
+//     HTTP Status Code 403: Access forbidden. Correct your credentials and then
+//     retry your request.
+//
+//   - ServiceUnavailableException
+//     HTTP Status Code 503: Service Unavailable. Retrying your request in some
+//     time might resolve the issue.
+//
+//   - TooManyRequestsException
+//     HTTP Status Code 429: Limit exceeded. Resource limit reached.
+//
+//   - UnauthorizedException
+//     HTTP Status Code 401: Unauthorized request. The provided credentials couldn't
+//     be validated.
+//
+//   - InternalServerErrorException
+//     HTTP Status Code 500: Unexpected internal server error. Retrying your request
+//     might resolve the issue.
+//
+// See also, https://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/TagResource
+func (c *KafkaConnect) TagResource(input *TagResourceInput) (*TagResourceOutput, error) {
+	req, out := c.TagResourceRequest(input)
+	return out, req.Send()
+}
+
+// TagResourceWithContext is the same as TagResource with the addition of
+// the ability to pass a context and additional request options.
+//
+// See TagResource for details on how to use this API operation.
+//
+// The context must be non-nil and will be used for request cancellation. If
+// the context is nil a panic will occur. In the future the SDK may create
+// sub-contexts for http.Requests. See https://golang.org/pkg/context/
+// for more information on using Contexts.
+func (c *KafkaConnect) TagResourceWithContext(ctx aws.Context, input *TagResourceInput, opts ...request.Option) (*TagResourceOutput, error) {
+	req, out := c.TagResourceRequest(input)
+	req.SetContext(ctx)
+	req.ApplyOptions(opts...)
+	return out, req.Send()
+}
+
+const opUntagResource = "UntagResource"
+
+// UntagResourceRequest generates a "aws/request.Request" representing the
+// client's request for the UntagResource operation. The "output" return
+// value will be populated with the request's response once the request completes
+// successfully.
+//
+// Use "Send" method on the returned Request to send the API call to the service.
+// the "output" return value is not valid until after Send returns without error.
+//
+// See UntagResource for more information on using the UntagResource
+// API call, and error handling.
+//
+// This method is useful when you want to inject custom logic or configuration
+// into the SDK's request lifecycle. Such as custom headers, or retry logic.
+//
+//	// Example sending a request using the UntagResourceRequest method.
+//	req, resp := client.UntagResourceRequest(params)
+//
+//	err := req.Send()
+//	if err == nil { // resp is now filled
+//	    fmt.Println(resp)
+//	}
+//
+// See also, https://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/UntagResource
+func (c *KafkaConnect) UntagResourceRequest(input *UntagResourceInput) (req *request.Request, output *UntagResourceOutput) {
+	op := &request.Operation{
+		Name:       opUntagResource,
+		HTTPMethod: "DELETE",
+		HTTPPath:   "/v1/tags/{resourceArn}",
+	}
+
+	if input == nil {
+		input = &UntagResourceInput{}
+	}
+
+	output = &UntagResourceOutput{}
+	req = c.newRequest(op, input, output)
+	req.Handlers.Unmarshal.Swap(restjson.UnmarshalHandler.Name, protocol.UnmarshalDiscardBodyHandler)
+	return
+}
+
+// UntagResource API operation for Managed Streaming for Kafka Connect.
+//
+// Removes tags from the specified resource.
+//
+// Returns awserr.Error for service API and SDK errors. Use runtime type assertions
+// with awserr.Error's Code and Message methods to get detailed information about
+// the error.
+//
+// See the AWS API reference guide for Managed Streaming for Kafka Connect's
+// API operation UntagResource for usage and error information.
+//
+// Returned Error Types:
+//
+//   - NotFoundException
+//     HTTP Status Code 404: Resource not found due to incorrect input. Correct
+//     your request and then retry it.
+//
+//   - BadRequestException
+//     HTTP Status Code 400: Bad request due to incorrect input. Correct your request
+//     and then retry it.
+//
+//   - ForbiddenException
+//     HTTP Status Code 403: Access forbidden. Correct your credentials and then
+//     retry your request.
+//
+//   - ServiceUnavailableException
+//     HTTP Status Code 503: Service Unavailable. Retrying your request in some
+//     time might resolve the issue.
+//
+//   - TooManyRequestsException
+//     HTTP Status Code 429: Limit exceeded. Resource limit reached.
+//
+//   - UnauthorizedException
+//     HTTP Status Code 401: Unauthorized request. The provided credentials couldn't
+//     be validated.
+//
+//   - InternalServerErrorException
+//     HTTP Status Code 500: Unexpected internal server error. Retrying your request
+//     might resolve the issue.
+//
+// See also, https://docs.aws.amazon.com/goto/WebAPI/kafkaconnect-2021-09-14/UntagResource
+func (c *KafkaConnect) UntagResource(input *UntagResourceInput) (*UntagResourceOutput, error) {
+	req, out := c.UntagResourceRequest(input)
+	return out, req.Send()
+}
+
+// UntagResourceWithContext is the same as UntagResource with the addition of
+// the ability to pass a context and additional request options.
+//
+// See UntagResource for details on how to use this API operation.
+//
+// The context must be non-nil and will be used for request cancellation. If
+// the context is nil a panic will occur. In the future the SDK may create
+// sub-contexts for http.Requests. See https://golang.org/pkg/context/
+// for more information on using Contexts.
+func (c *KafkaConnect) UntagResourceWithContext(ctx aws.Context, input *UntagResourceInput, opts ...request.Option) (*UntagResourceOutput, error) {
+	req, out := c.UntagResourceRequest(input)
+	req.SetContext(ctx)
+	req.ApplyOptions(opts...)
+	return out, req.Send()
+}
+
 const opUpdateConnector = "UpdateConnector"
 
 // UpdateConnectorRequest generates a "aws/request.Request" representing the
@@ -2450,7 +2869,13 @@ type CreateConnectorInput struct {
 	// Details about log delivery.
 	LogDelivery *LogDelivery `locationName:"logDelivery" type:"structure"`
 
-	// Specifies which plugins to use for the connector.
+	//
+	// Amazon MSK Connect does not currently support specifying multiple plugins
+	// as a list. To use more than one plugin for your connector, you can create
+	// a single custom plugin using a ZIP file that bundles multiple plugins together.
+	//
+	// Specifies which plugin to use for the connector. You must specify a single-element
+	// list containing one customPlugin object.
 	//
 	// Plugins is a required field
 	Plugins []*Plugin `locationName:"plugins" type:"list" required:"true"`
@@ -2464,6 +2889,9 @@ type CreateConnectorInput struct {
 	// ServiceExecutionRoleArn is a required field
 	ServiceExecutionRoleArn *string `locationName:"serviceExecutionRoleArn" type:"string" required:"true"`
 
+	// The tags you want to attach to the connector.
+	Tags map[string]*string `locationName:"tags" type:"map"`
+
 	// Specifies which worker configuration to use with the connector.
 	WorkerConfiguration *WorkerConfiguration `locationName:"workerConfiguration" type:"structure"`
 }
@@ -2632,6 +3060,12 @@ func (s *CreateConnectorInput) SetServiceExecutionRoleArn(v string) *CreateConne
 	return s
 }
 
+// SetTags sets the Tags field's value.
+func (s *CreateConnectorInput) SetTags(v map[string]*string) *CreateConnectorInput {
+	s.Tags = v
+	return s
+}
+
 // SetWorkerConfiguration sets the WorkerConfiguration field's value.
 func (s *CreateConnectorInput) SetWorkerConfiguration(v *WorkerConfiguration) *CreateConnectorInput {
 	s.WorkerConfiguration = v
@@ -2707,6 +3141,9 @@ type CreateCustomPluginInput struct {
 	//
 	// Name is a required field
 	Name *string `locationName:"name" min:"1" type:"string" required:"true"`
+
+	// The tags you want to attach to the custom plugin.
+	Tags map[string]*string `locationName:"tags" type:"map"`
 }
 
 // String returns the string representation.
@@ -2778,6 +3215,12 @@ func (s *CreateCustomPluginInput) SetName(v string) *CreateCustomPluginInput {
 	return s
 }
 
+// SetTags sets the Tags field's value.
+func (s *CreateCustomPluginInput) SetTags(v map[string]*string) *CreateCustomPluginInput {
+	s.Tags = v
+	return s
+}
+
 type CreateCustomPluginOutput struct {
 	_ struct{} `type:"structure"`
 
@@ -2855,6 +3298,9 @@ type CreateWorkerConfigurationInput struct {
 	//
 	// PropertiesFileContent is a required field
 	PropertiesFileContent *string `locationName:"propertiesFileContent" type:"string" required:"true" sensitive:"true"`
+
+	// The tags you want to attach to the worker configuration.
+	Tags map[string]*string `locationName:"tags" type:"map"`
 }
 
 // String returns the string representation.
@@ -2912,6 +3358,12 @@ func (s *CreateWorkerConfigurationInput) SetPropertiesFileContent(v string) *Cre
 	return s
 }
 
+// SetTags sets the Tags field's value.
+func (s *CreateWorkerConfigurationInput) SetTags(v map[string]*string) *CreateWorkerConfigurationInput {
+	s.Tags = v
+	return s
+}
+
 type CreateWorkerConfigurationOutput struct {
 	_ struct{} `type:"structure"`
 
@@ -2926,6 +3378,9 @@ type CreateWorkerConfigurationOutput struct {
 
 	// The Amazon Resource Name (ARN) that Amazon assigned to the worker configuration.
 	WorkerConfigurationArn *string `locationName:"workerConfigurationArn" type:"string"`
+
+	// The state of the worker configuration.
+	WorkerConfigurationState *string `locationName:"workerConfigurationState" type:"string" enum:"WorkerConfigurationState"`
 }
 
 // String returns the string representation.
@@ -2970,8 +3425,14 @@ func (s *CreateWorkerConfigurationOutput) SetWorkerConfigurationArn(v string) *C
 	return s
 }
 
-// A plugin is an AWS resource that contains the code that defines a connector's
-// logic.
+// SetWorkerConfigurationState sets the WorkerConfigurationState field's value.
+func (s *CreateWorkerConfigurationOutput) SetWorkerConfigurationState(v string) *CreateWorkerConfigurationOutput {
+	s.WorkerConfigurationState = &v
+	return s
+}
+
+// A plugin is an Amazon Web Services resource that contains the code that defines
+// a connector's logic.
 type CustomPlugin struct {
 	_ struct{} `type:"structure"`
 
@@ -3441,29 +3902,120 @@ func (s DeleteConnectorOutput) String() string {
 // API parameter values that are decorated as "sensitive" in the API will not
 // be included in the string output. The member name will be present, but the
 // value will be replaced with "sensitive".
-func (s DeleteConnectorOutput) GoString() string {
+func (s DeleteConnectorOutput) GoString() string {
+	return s.String()
+}
+
+// SetConnectorArn sets the ConnectorArn field's value.
+func (s *DeleteConnectorOutput) SetConnectorArn(v string) *DeleteConnectorOutput {
+	s.ConnectorArn = &v
+	return s
+}
+
+// SetConnectorState sets the ConnectorState field's value.
+func (s *DeleteConnectorOutput) SetConnectorState(v string) *DeleteConnectorOutput {
+	s.ConnectorState = &v
+	return s
+}
+
+type DeleteCustomPluginInput struct {
+	_ struct{} `type:"structure" nopayload:"true"`
+
+	// The Amazon Resource Name (ARN) of the custom plugin that you want to delete.
+	//
+	// CustomPluginArn is a required field
+	CustomPluginArn *string `location:"uri" locationName:"customPluginArn" type:"string" required:"true"`
+}
+
+// String returns the string representation.
+//
+// API parameter values that are decorated as "sensitive" in the API will not
+// be included in the string output. The member name will be present, but the
+// value will be replaced with "sensitive".
+func (s DeleteCustomPluginInput) String() string {
+	return awsutil.Prettify(s)
+}
+
+// GoString returns the string representation.
+//
+// API parameter values that are decorated as "sensitive" in the API will not
+// be included in the string output. The member name will be present, but the
+// value will be replaced with "sensitive".
+func (s DeleteCustomPluginInput) GoString() string {
+	return s.String()
+}
+
+// Validate inspects the fields of the type to determine if they are valid.
+func (s *DeleteCustomPluginInput) Validate() error {
+	invalidParams := request.ErrInvalidParams{Context: "DeleteCustomPluginInput"}
+	if s.CustomPluginArn == nil {
+		invalidParams.Add(request.NewErrParamRequired("CustomPluginArn"))
+	}
+	if s.CustomPluginArn != nil && len(*s.CustomPluginArn) < 1 {
+		invalidParams.Add(request.NewErrParamMinLen("CustomPluginArn", 1))
+	}
+
+	if invalidParams.Len() > 0 {
+		return invalidParams
+	}
+	return nil
+}
+
+// SetCustomPluginArn sets the CustomPluginArn field's value.
+func (s *DeleteCustomPluginInput) SetCustomPluginArn(v string) *DeleteCustomPluginInput {
+	s.CustomPluginArn = &v
+	return s
+}
+
+type DeleteCustomPluginOutput struct {
+	_ struct{} `type:"structure"`
+
+	// The Amazon Resource Name (ARN) of the custom plugin that you requested to
+	// delete.
+	CustomPluginArn *string `locationName:"customPluginArn" type:"string"`
+
+	// The state of the custom plugin.
+	CustomPluginState *string `locationName:"customPluginState" type:"string" enum:"CustomPluginState"`
+}
+
+// String returns the string representation.
+//
+// API parameter values that are decorated as "sensitive" in the API will not
+// be included in the string output. The member name will be present, but the
+// value will be replaced with "sensitive".
+func (s DeleteCustomPluginOutput) String() string {
+	return awsutil.Prettify(s)
+}
+
+// GoString returns the string representation.
+//
+// API parameter values that are decorated as "sensitive" in the API will not
+// be included in the string output. The member name will be present, but the
+// value will be replaced with "sensitive".
+func (s DeleteCustomPluginOutput) GoString() string {
 	return s.String()
 }
 
-// SetConnectorArn sets the ConnectorArn field's value.
-func (s *DeleteConnectorOutput) SetConnectorArn(v string) *DeleteConnectorOutput {
-	s.ConnectorArn = &v
+// SetCustomPluginArn sets the CustomPluginArn field's value.
+func (s *DeleteCustomPluginOutput) SetCustomPluginArn(v string) *DeleteCustomPluginOutput {
+	s.CustomPluginArn = &v
 	return s
 }
 
-// SetConnectorState sets the ConnectorState field's value.
-func (s *DeleteConnectorOutput) SetConnectorState(v string) *DeleteConnectorOutput {
-	s.ConnectorState = &v
+// SetCustomPluginState sets the CustomPluginState field's value.
+func (s *DeleteCustomPluginOutput) SetCustomPluginState(v string) *DeleteCustomPluginOutput {
+	s.CustomPluginState = &v
 	return s
 }
 
-type DeleteCustomPluginInput struct {
+type DeleteWorkerConfigurationInput struct {
 	_ struct{} `type:"structure" nopayload:"true"`
 
-	// The Amazon Resource Name (ARN) of the custom plugin that you want to delete.
+	// The Amazon Resource Name (ARN) of the worker configuration that you want
+	// to delete.
 	//
-	// CustomPluginArn is a required field
-	CustomPluginArn *string `location:"uri" locationName:"customPluginArn" type:"string" required:"true"`
+	// WorkerConfigurationArn is a required field
+	WorkerConfigurationArn *string `location:"uri" locationName:"workerConfigurationArn" type:"string" required:"true"`
 }
 
 // String returns the string representation.
@@ -3471,7 +4023,7 @@ type DeleteCustomPluginInput struct {
 // API parameter values that are decorated as "sensitive" in the API will not
 // be included in the string output. The member name will be present, but the
 // value will be replaced with "sensitive".
-func (s DeleteCustomPluginInput) String() string {
+func (s DeleteWorkerConfigurationInput) String() string {
 	return awsutil.Prettify(s)
 }
 
@@ -3480,18 +4032,18 @@ func (s DeleteCustomPluginInput) String() string {
 // API parameter values that are decorated as "sensitive" in the API will not
 // be included in the string output. The member name will be present, but the
 // value will be replaced with "sensitive".
-func (s DeleteCustomPluginInput) GoString() string {
+func (s DeleteWorkerConfigurationInput) GoString() string {
 	return s.String()
 }
 
 // Validate inspects the fields of the type to determine if they are valid.
-func (s *DeleteCustomPluginInput) Validate() error {
-	invalidParams := request.ErrInvalidParams{Context: "DeleteCustomPluginInput"}
-	if s.CustomPluginArn == nil {
-		invalidParams.Add(request.NewErrParamRequired("CustomPluginArn"))
+func (s *DeleteWorkerConfigurationInput) Validate() error {
+	invalidParams := request.ErrInvalidParams{Context: "DeleteWorkerConfigurationInput"}
+	if s.WorkerConfigurationArn == nil {
+		invalidParams.Add(request.NewErrParamRequired("WorkerConfigurationArn"))
 	}
-	if s.CustomPluginArn != nil && len(*s.CustomPluginArn) < 1 {
-		invalidParams.Add(request.NewErrParamMinLen("CustomPluginArn", 1))
+	if s.WorkerConfigurationArn != nil && len(*s.WorkerConfigurationArn) < 1 {
+		invalidParams.Add(request.NewErrParamMinLen("WorkerConfigurationArn", 1))
 	}
 
 	if invalidParams.Len() > 0 {
@@ -3500,21 +4052,21 @@ func (s *DeleteCustomPluginInput) Validate() error {
 	return nil
 }
 
-// SetCustomPluginArn sets the CustomPluginArn field's value.
-func (s *DeleteCustomPluginInput) SetCustomPluginArn(v string) *DeleteCustomPluginInput {
-	s.CustomPluginArn = &v
+// SetWorkerConfigurationArn sets the WorkerConfigurationArn field's value.
+func (s *DeleteWorkerConfigurationInput) SetWorkerConfigurationArn(v string) *DeleteWorkerConfigurationInput {
+	s.WorkerConfigurationArn = &v
 	return s
 }
 
-type DeleteCustomPluginOutput struct {
+type DeleteWorkerConfigurationOutput struct {
 	_ struct{} `type:"structure"`
 
-	// The Amazon Resource Name (ARN) of the custom plugin that you requested to
-	// delete.
-	CustomPluginArn *string `locationName:"customPluginArn" type:"string"`
+	// The Amazon Resource Name (ARN) of the worker configuration that you requested
+	// to delete.
+	WorkerConfigurationArn *string `locationName:"workerConfigurationArn" type:"string"`
 
-	// The state of the custom plugin.
-	CustomPluginState *string `locationName:"customPluginState" type:"string" enum:"CustomPluginState"`
+	// The state of the worker configuration.
+	WorkerConfigurationState *string `locationName:"workerConfigurationState" type:"string" enum:"WorkerConfigurationState"`
 }
 
 // String returns the string representation.
@@ -3522,7 +4074,7 @@ type DeleteCustomPluginOutput struct {
 // API parameter values that are decorated as "sensitive" in the API will not
 // be included in the string output. The member name will be present, but the
 // value will be replaced with "sensitive".
-func (s DeleteCustomPluginOutput) String() string {
+func (s DeleteWorkerConfigurationOutput) String() string {
 	return awsutil.Prettify(s)
 }
 
@@ -3531,19 +4083,19 @@ func (s DeleteCustomPluginOutput) String() string {
 // API parameter values that are decorated as "sensitive" in the API will not
 // be included in the string output. The member name will be present, but the
 // value will be replaced with "sensitive".
-func (s DeleteCustomPluginOutput) GoString() string {
+func (s DeleteWorkerConfigurationOutput) GoString() string {
 	return s.String()
 }
 
-// SetCustomPluginArn sets the CustomPluginArn field's value.
-func (s *DeleteCustomPluginOutput) SetCustomPluginArn(v string) *DeleteCustomPluginOutput {
-	s.CustomPluginArn = &v
+// SetWorkerConfigurationArn sets the WorkerConfigurationArn field's value.
+func (s *DeleteWorkerConfigurationOutput) SetWorkerConfigurationArn(v string) *DeleteWorkerConfigurationOutput {
+	s.WorkerConfigurationArn = &v
 	return s
 }
 
-// SetCustomPluginState sets the CustomPluginState field's value.
-func (s *DeleteCustomPluginOutput) SetCustomPluginState(v string) *DeleteCustomPluginOutput {
-	s.CustomPluginState = &v
+// SetWorkerConfigurationState sets the WorkerConfigurationState field's value.
+func (s *DeleteWorkerConfigurationOutput) SetWorkerConfigurationState(v string) *DeleteWorkerConfigurationOutput {
+	s.WorkerConfigurationState = &v
 	return s
 }
 
@@ -3981,6 +4533,9 @@ type DescribeWorkerConfigurationOutput struct {
 
 	// The Amazon Resource Name (ARN) of the custom configuration.
 	WorkerConfigurationArn *string `locationName:"workerConfigurationArn" type:"string"`
+
+	// The state of the worker configuration.
+	WorkerConfigurationState *string `locationName:"workerConfigurationState" type:"string" enum:"WorkerConfigurationState"`
 }
 
 // String returns the string representation.
@@ -4031,6 +4586,12 @@ func (s *DescribeWorkerConfigurationOutput) SetWorkerConfigurationArn(v string)
 	return s
 }
 
+// SetWorkerConfigurationState sets the WorkerConfigurationState field's value.
+func (s *DescribeWorkerConfigurationOutput) SetWorkerConfigurationState(v string) *DescribeWorkerConfigurationOutput {
+	s.WorkerConfigurationState = &v
+	return s
+}
+
 // The settings for delivering logs to Amazon Kinesis Data Firehose.
 type FirehoseLogDelivery struct {
 	_ struct{} `type:"structure"`
@@ -4619,6 +5180,9 @@ type ListCustomPluginsInput struct {
 	// The maximum number of custom plugins to list in one response.
 	MaxResults *int64 `location:"querystring" locationName:"maxResults" min:"1" type:"integer"`
 
+	// Lists custom plugin names that start with the specified text string.
+	NamePrefix *string `location:"querystring" locationName:"namePrefix" type:"string"`
+
 	// If the response of a ListCustomPlugins operation is truncated, it will include
 	// a NextToken. Send this NextToken in a subsequent request to continue listing
 	// from where the previous operation left off.
@@ -4662,6 +5226,12 @@ func (s *ListCustomPluginsInput) SetMaxResults(v int64) *ListCustomPluginsInput
 	return s
 }
 
+// SetNamePrefix sets the NamePrefix field's value.
+func (s *ListCustomPluginsInput) SetNamePrefix(v string) *ListCustomPluginsInput {
+	s.NamePrefix = &v
+	return s
+}
+
 // SetNextToken sets the NextToken field's value.
 func (s *ListCustomPluginsInput) SetNextToken(v string) *ListCustomPluginsInput {
 	s.NextToken = &v
@@ -4710,12 +5280,96 @@ func (s *ListCustomPluginsOutput) SetNextToken(v string) *ListCustomPluginsOutpu
 	return s
 }
 
+type ListTagsForResourceInput struct {
+	_ struct{} `type:"structure" nopayload:"true"`
+
+	// The Amazon Resource Name (ARN) of the resource for which you want to list
+	// all attached tags.
+	//
+	// ResourceArn is a required field
+	ResourceArn *string `location:"uri" locationName:"resourceArn" type:"string" required:"true"`
+}
+
+// String returns the string representation.
+//
+// API parameter values that are decorated as "sensitive" in the API will not
+// be included in the string output. The member name will be present, but the
+// value will be replaced with "sensitive".
+func (s ListTagsForResourceInput) String() string {
+	return awsutil.Prettify(s)
+}
+
+// GoString returns the string representation.
+//
+// API parameter values that are decorated as "sensitive" in the API will not
+// be included in the string output. The member name will be present, but the
+// value will be replaced with "sensitive".
+func (s ListTagsForResourceInput) GoString() string {
+	return s.String()
+}
+
+// Validate inspects the fields of the type to determine if they are valid.
+func (s *ListTagsForResourceInput) Validate() error {
+	invalidParams := request.ErrInvalidParams{Context: "ListTagsForResourceInput"}
+	if s.ResourceArn == nil {
+		invalidParams.Add(request.NewErrParamRequired("ResourceArn"))
+	}
+	if s.ResourceArn != nil && len(*s.ResourceArn) < 1 {
+		invalidParams.Add(request.NewErrParamMinLen("ResourceArn", 1))
+	}
+
+	if invalidParams.Len() > 0 {
+		return invalidParams
+	}
+	return nil
+}
+
+// SetResourceArn sets the ResourceArn field's value.
+func (s *ListTagsForResourceInput) SetResourceArn(v string) *ListTagsForResourceInput {
+	s.ResourceArn = &v
+	return s
+}
+
+type ListTagsForResourceOutput struct {
+	_ struct{} `type:"structure"`
+
+	// Lists the tags attached to the specified resource in the corresponding request.
+	Tags map[string]*string `locationName:"tags" type:"map"`
+}
+
+// String returns the string representation.
+//
+// API parameter values that are decorated as "sensitive" in the API will not
+// be included in the string output. The member name will be present, but the
+// value will be replaced with "sensitive".
+func (s ListTagsForResourceOutput) String() string {
+	return awsutil.Prettify(s)
+}
+
+// GoString returns the string representation.
+//
+// API parameter values that are decorated as "sensitive" in the API will not
+// be included in the string output. The member name will be present, but the
+// value will be replaced with "sensitive".
+func (s ListTagsForResourceOutput) GoString() string {
+	return s.String()
+}
+
+// SetTags sets the Tags field's value.
+func (s *ListTagsForResourceOutput) SetTags(v map[string]*string) *ListTagsForResourceOutput {
+	s.Tags = v
+	return s
+}
+
 type ListWorkerConfigurationsInput struct {
 	_ struct{} `type:"structure" nopayload:"true"`
 
 	// The maximum number of worker configurations to list in one response.
 	MaxResults *int64 `location:"querystring" locationName:"maxResults" min:"1" type:"integer"`
 
+	// Lists worker configuration names that start with the specified text string.
+	NamePrefix *string `location:"querystring" locationName:"namePrefix" type:"string"`
+
 	// If the response of a ListWorkerConfigurations operation is truncated, it
 	// will include a NextToken. Send this NextToken in a subsequent request to
 	// continue listing from where the previous operation left off.
@@ -4759,6 +5413,12 @@ func (s *ListWorkerConfigurationsInput) SetMaxResults(v int64) *ListWorkerConfig
 	return s
 }
 
+// SetNamePrefix sets the NamePrefix field's value.
+func (s *ListWorkerConfigurationsInput) SetNamePrefix(v string) *ListWorkerConfigurationsInput {
+	s.NamePrefix = &v
+	return s
+}
+
 // SetNextToken sets the NextToken field's value.
 func (s *ListWorkerConfigurationsInput) SetNextToken(v string) *ListWorkerConfigurationsInput {
 	s.NextToken = &v
@@ -4958,8 +5618,8 @@ func (s *NotFoundException) RequestID() string {
 	return s.RespMetadata.RequestID
 }
 
-// A plugin is an AWS resource that contains the code that defines your connector
-// logic.
+// A plugin is an Amazon Web Services resource that contains the code that defines
+// your connector logic.
 type Plugin struct {
 	_ struct{} `type:"structure"`
 
@@ -5832,6 +6492,92 @@ func (s *StateDescription) SetMessage(v string) *StateDescription {
 	return s
 }
 
+type TagResourceInput struct {
+	_ struct{} `type:"structure"`
+
+	// The Amazon Resource Name (ARN) of the resource to which you want to attach
+	// tags.
+	//
+	// ResourceArn is a required field
+	ResourceArn *string `location:"uri" locationName:"resourceArn" type:"string" required:"true"`
+
+	// The tags that you want to attach to the resource.
+	//
+	// Tags is a required field
+	Tags map[string]*string `locationName:"tags" type:"map" required:"true"`
+}
+
+// String returns the string representation.
+//
+// API parameter values that are decorated as "sensitive" in the API will not
+// be included in the string output. The member name will be present, but the
+// value will be replaced with "sensitive".
+func (s TagResourceInput) String() string {
+	return awsutil.Prettify(s)
+}
+
+// GoString returns the string representation.
+//
+// API parameter values that are decorated as "sensitive" in the API will not
+// be included in the string output. The member name will be present, but the
+// value will be replaced with "sensitive".
+func (s TagResourceInput) GoString() string {
+	return s.String()
+}
+
+// Validate inspects the fields of the type to determine if they are valid.
+func (s *TagResourceInput) Validate() error {
+	invalidParams := request.ErrInvalidParams{Context: "TagResourceInput"}
+	if s.ResourceArn == nil {
+		invalidParams.Add(request.NewErrParamRequired("ResourceArn"))
+	}
+	if s.ResourceArn != nil && len(*s.ResourceArn) < 1 {
+		invalidParams.Add(request.NewErrParamMinLen("ResourceArn", 1))
+	}
+	if s.Tags == nil {
+		invalidParams.Add(request.NewErrParamRequired("Tags"))
+	}
+
+	if invalidParams.Len() > 0 {
+		return invalidParams
+	}
+	return nil
+}
+
+// SetResourceArn sets the ResourceArn field's value.
+func (s *TagResourceInput) SetResourceArn(v string) *TagResourceInput {
+	s.ResourceArn = &v
+	return s
+}
+
+// SetTags sets the Tags field's value.
+func (s *TagResourceInput) SetTags(v map[string]*string) *TagResourceInput {
+	s.Tags = v
+	return s
+}
+
+type TagResourceOutput struct {
+	_ struct{} `type:"structure"`
+}
+
+// String returns the string representation.
+//
+// API parameter values that are decorated as "sensitive" in the API will not
+// be included in the string output. The member name will be present, but the
+// value will be replaced with "sensitive".
+func (s TagResourceOutput) String() string {
+	return awsutil.Prettify(s)
+}
+
+// GoString returns the string representation.
+//
+// API parameter values that are decorated as "sensitive" in the API will not
+// be included in the string output. The member name will be present, but the
+// value will be replaced with "sensitive".
+func (s TagResourceOutput) GoString() string {
+	return s.String()
+}
+
 // HTTP Status Code 429: Limit exceeded. Resource limit reached.
 type TooManyRequestsException struct {
 	_            struct{}                  `type:"structure"`
@@ -5961,6 +6707,92 @@ func (s *UnauthorizedException) RequestID() string {
 	return s.RespMetadata.RequestID
 }
 
+type UntagResourceInput struct {
+	_ struct{} `type:"structure" nopayload:"true"`
+
+	// The Amazon Resource Name (ARN) of the resource from which you want to remove
+	// tags.
+	//
+	// ResourceArn is a required field
+	ResourceArn *string `location:"uri" locationName:"resourceArn" type:"string" required:"true"`
+
+	// The keys of the tags that you want to remove from the resource.
+	//
+	// TagKeys is a required field
+	TagKeys []*string `location:"querystring" locationName:"tagKeys" type:"list" required:"true"`
+}
+
+// String returns the string representation.
+//
+// API parameter values that are decorated as "sensitive" in the API will not
+// be included in the string output. The member name will be present, but the
+// value will be replaced with "sensitive".
+func (s UntagResourceInput) String() string {
+	return awsutil.Prettify(s)
+}
+
+// GoString returns the string representation.
+//
+// API parameter values that are decorated as "sensitive" in the API will not
+// be included in the string output. The member name will be present, but the
+// value will be replaced with "sensitive".
+func (s UntagResourceInput) GoString() string {
+	return s.String()
+}
+
+// Validate inspects the fields of the type to determine if they are valid.
+func (s *UntagResourceInput) Validate() error {
+	invalidParams := request.ErrInvalidParams{Context: "UntagResourceInput"}
+	if s.ResourceArn == nil {
+		invalidParams.Add(request.NewErrParamRequired("ResourceArn"))
+	}
+	if s.ResourceArn != nil && len(*s.ResourceArn) < 1 {
+		invalidParams.Add(request.NewErrParamMinLen("ResourceArn", 1))
+	}
+	if s.TagKeys == nil {
+		invalidParams.Add(request.NewErrParamRequired("TagKeys"))
+	}
+
+	if invalidParams.Len() > 0 {
+		return invalidParams
+	}
+	return nil
+}
+
+// SetResourceArn sets the ResourceArn field's value.
+func (s *UntagResourceInput) SetResourceArn(v string) *UntagResourceInput {
+	s.ResourceArn = &v
+	return s
+}
+
+// SetTagKeys sets the TagKeys field's value.
+func (s *UntagResourceInput) SetTagKeys(v []*string) *UntagResourceInput {
+	s.TagKeys = v
+	return s
+}
+
+type UntagResourceOutput struct {
+	_ struct{} `type:"structure"`
+}
+
+// String returns the string representation.
+//
+// API parameter values that are decorated as "sensitive" in the API will not
+// be included in the string output. The member name will be present, but the
+// value will be replaced with "sensitive".
+func (s UntagResourceOutput) String() string {
+	return awsutil.Prettify(s)
+}
+
+// GoString returns the string representation.
+//
+// API parameter values that are decorated as "sensitive" in the API will not
+// be included in the string output. The member name will be present, but the
+// value will be replaced with "sensitive".
+func (s UntagResourceOutput) GoString() string {
+	return s.String()
+}
+
 type UpdateConnectorInput struct {
 	_ struct{} `type:"structure"`
 
@@ -6417,6 +7249,9 @@ type WorkerConfigurationSummary struct {
 
 	// The Amazon Resource Name (ARN) of the worker configuration.
 	WorkerConfigurationArn *string `locationName:"workerConfigurationArn" type:"string"`
+
+	// The state of the worker configuration.
+	WorkerConfigurationState *string `locationName:"workerConfigurationState" type:"string" enum:"WorkerConfigurationState"`
 }
 
 // String returns the string representation.
@@ -6467,6 +7302,12 @@ func (s *WorkerConfigurationSummary) SetWorkerConfigurationArn(v string) *Worker
 	return s
 }
 
+// SetWorkerConfigurationState sets the WorkerConfigurationState field's value.
+func (s *WorkerConfigurationSummary) SetWorkerConfigurationState(v string) *WorkerConfigurationSummary {
+	s.WorkerConfigurationState = &v
+	return s
+}
+
 // Workers can send worker logs to different destination types. This configuration
 // specifies the details of these destinations.
 type WorkerLogDelivery struct {
@@ -6701,3 +7542,19 @@ func KafkaClusterEncryptionInTransitType_Values() []string {
 		KafkaClusterEncryptionInTransitTypeTls,
 	}
 }
+
+const (
+	// WorkerConfigurationStateActive is a WorkerConfigurationState enum value
+	WorkerConfigurationStateActive = "ACTIVE"
+
+	// WorkerConfigurationStateDeleting is a WorkerConfigurationState enum value
+	WorkerConfigurationStateDeleting = "DELETING"
+)
+
+// WorkerConfigurationState_Values returns all elements of the WorkerConfigurationState enum
+func WorkerConfigurationState_Values() []string {
+	return []string{
+		WorkerConfigurationStateActive,
+		WorkerConfigurationStateDeleting,
+	}
+}
diff --git a/service/kafkaconnect/kafkaconnectiface/interface.go b/service/kafkaconnect/kafkaconnectiface/interface.go
index 74343840d38..94f080afec5 100644
--- a/service/kafkaconnect/kafkaconnectiface/interface.go
+++ b/service/kafkaconnect/kafkaconnectiface/interface.go
@@ -80,6 +80,10 @@ type KafkaConnectAPI interface {
 	DeleteCustomPluginWithContext(aws.Context, *kafkaconnect.DeleteCustomPluginInput, ...request.Option) (*kafkaconnect.DeleteCustomPluginOutput, error)
 	DeleteCustomPluginRequest(*kafkaconnect.DeleteCustomPluginInput) (*request.Request, *kafkaconnect.DeleteCustomPluginOutput)
 
+	DeleteWorkerConfiguration(*kafkaconnect.DeleteWorkerConfigurationInput) (*kafkaconnect.DeleteWorkerConfigurationOutput, error)
+	DeleteWorkerConfigurationWithContext(aws.Context, *kafkaconnect.DeleteWorkerConfigurationInput, ...request.Option) (*kafkaconnect.DeleteWorkerConfigurationOutput, error)
+	DeleteWorkerConfigurationRequest(*kafkaconnect.DeleteWorkerConfigurationInput) (*request.Request, *kafkaconnect.DeleteWorkerConfigurationOutput)
+
 	DescribeConnector(*kafkaconnect.DescribeConnectorInput) (*kafkaconnect.DescribeConnectorOutput, error)
 	DescribeConnectorWithContext(aws.Context, *kafkaconnect.DescribeConnectorInput, ...request.Option) (*kafkaconnect.DescribeConnectorOutput, error)
 	DescribeConnectorRequest(*kafkaconnect.DescribeConnectorInput) (*request.Request, *kafkaconnect.DescribeConnectorOutput)
@@ -106,6 +110,10 @@ type KafkaConnectAPI interface {
 	ListCustomPluginsPages(*kafkaconnect.ListCustomPluginsInput, func(*kafkaconnect.ListCustomPluginsOutput, bool) bool) error
 	ListCustomPluginsPagesWithContext(aws.Context, *kafkaconnect.ListCustomPluginsInput, func(*kafkaconnect.ListCustomPluginsOutput, bool) bool, ...request.Option) error
 
+	ListTagsForResource(*kafkaconnect.ListTagsForResourceInput) (*kafkaconnect.ListTagsForResourceOutput, error)
+	ListTagsForResourceWithContext(aws.Context, *kafkaconnect.ListTagsForResourceInput, ...request.Option) (*kafkaconnect.ListTagsForResourceOutput, error)
+	ListTagsForResourceRequest(*kafkaconnect.ListTagsForResourceInput) (*request.Request, *kafkaconnect.ListTagsForResourceOutput)
+
 	ListWorkerConfigurations(*kafkaconnect.ListWorkerConfigurationsInput) (*kafkaconnect.ListWorkerConfigurationsOutput, error)
 	ListWorkerConfigurationsWithContext(aws.Context, *kafkaconnect.ListWorkerConfigurationsInput, ...request.Option) (*kafkaconnect.ListWorkerConfigurationsOutput, error)
 	ListWorkerConfigurationsRequest(*kafkaconnect.ListWorkerConfigurationsInput) (*request.Request, *kafkaconnect.ListWorkerConfigurationsOutput)
@@ -113,6 +121,14 @@ type KafkaConnectAPI interface {
 	ListWorkerConfigurationsPages(*kafkaconnect.ListWorkerConfigurationsInput, func(*kafkaconnect.ListWorkerConfigurationsOutput, bool) bool) error
 	ListWorkerConfigurationsPagesWithContext(aws.Context, *kafkaconnect.ListWorkerConfigurationsInput, func(*kafkaconnect.ListWorkerConfigurationsOutput, bool) bool, ...request.Option) error
 
+	TagResource(*kafkaconnect.TagResourceInput) (*kafkaconnect.TagResourceOutput, error)
+	TagResourceWithContext(aws.Context, *kafkaconnect.TagResourceInput, ...request.Option) (*kafkaconnect.TagResourceOutput, error)
+	TagResourceRequest(*kafkaconnect.TagResourceInput) (*request.Request, *kafkaconnect.TagResourceOutput)
+
+	UntagResource(*kafkaconnect.UntagResourceInput) (*kafkaconnect.UntagResourceOutput, error)
+	UntagResourceWithContext(aws.Context, *kafkaconnect.UntagResourceInput, ...request.Option) (*kafkaconnect.UntagResourceOutput, error)
+	UntagResourceRequest(*kafkaconnect.UntagResourceInput) (*request.Request, *kafkaconnect.UntagResourceOutput)
+
 	UpdateConnector(*kafkaconnect.UpdateConnectorInput) (*kafkaconnect.UpdateConnectorOutput, error)
 	UpdateConnectorWithContext(aws.Context, *kafkaconnect.UpdateConnectorInput, ...request.Option) (*kafkaconnect.UpdateConnectorOutput, error)
 	UpdateConnectorRequest(*kafkaconnect.UpdateConnectorInput) (*request.Request, *kafkaconnect.UpdateConnectorOutput)
diff --git a/service/rds/api.go b/service/rds/api.go
index 079d2f53249..3924ac6a894 100644
--- a/service/rds/api.go
+++ b/service/rds/api.go
@@ -28152,6 +28152,12 @@ type DBCluster struct {
 	// Indicates whether the DB cluster is encrypted.
 	StorageEncrypted *bool `type:"boolean"`
 
+	// The storage throughput for the DB cluster. The throughput is automatically
+	// set based on the IOPS that you provision, and is not configurable.
+	//
+	// This setting is only for non-Aurora Multi-AZ DB clusters.
+	StorageThroughput *int64 `type:"integer"`
+
 	// The storage type associated with the DB cluster.
 	StorageType *string `type:"string"`
 
@@ -28625,6 +28631,12 @@ func (s *DBCluster) SetStorageEncrypted(v bool) *DBCluster {
 	return s
 }
 
+// SetStorageThroughput sets the StorageThroughput field's value.
+func (s *DBCluster) SetStorageThroughput(v int64) *DBCluster {
+	s.StorageThroughput = &v
+	return s
+}
+
 // SetStorageType sets the StorageType field's value.
 func (s *DBCluster) SetStorageType(v string) *DBCluster {
 	s.StorageType = &v
@@ -28735,6 +28747,12 @@ type DBClusterAutomatedBackup struct {
 	// Indicates whether the source DB cluster is encrypted.
 	StorageEncrypted *bool `type:"boolean"`
 
+	// The storage throughput for the automated backup. The throughput is automatically
+	// set based on the IOPS that you provision, and is not configurable.
+	//
+	// This setting is only for non-Aurora Multi-AZ DB clusters.
+	StorageThroughput *int64 `type:"integer"`
+
 	// The storage type associated with the DB cluster.
 	//
 	// This setting is only for non-Aurora Multi-AZ DB clusters.
@@ -28894,6 +28912,12 @@ func (s *DBClusterAutomatedBackup) SetStorageEncrypted(v bool) *DBClusterAutomat
 	return s
 }
 
+// SetStorageThroughput sets the StorageThroughput field's value.
+func (s *DBClusterAutomatedBackup) SetStorageThroughput(v int64) *DBClusterAutomatedBackup {
+	s.StorageThroughput = &v
+	return s
+}
+
 // SetStorageType sets the StorageType field's value.
 func (s *DBClusterAutomatedBackup) SetStorageType(v string) *DBClusterAutomatedBackup {
 	s.StorageType = &v
@@ -29403,6 +29427,12 @@ type DBClusterSnapshot struct {
 	// Indicates whether the DB cluster snapshot is encrypted.
 	StorageEncrypted *bool `type:"boolean"`
 
+	// The storage throughput for the DB cluster snapshot. The throughput is automatically
+	// set based on the IOPS that you provision, and is not configurable.
+	//
+	// This setting is only for non-Aurora Multi-AZ DB clusters.
+	StorageThroughput *int64 `type:"integer"`
+
 	// The storage type associated with the DB cluster snapshot.
 	//
 	// This setting is only for Aurora DB clusters.
@@ -29566,6 +29596,12 @@ func (s *DBClusterSnapshot) SetStorageEncrypted(v bool) *DBClusterSnapshot {
 	return s
 }
 
+// SetStorageThroughput sets the StorageThroughput field's value.
+func (s *DBClusterSnapshot) SetStorageThroughput(v int64) *DBClusterSnapshot {
+	s.StorageThroughput = &v
+	return s
+}
+
 // SetStorageType sets the StorageType field's value.
 func (s *DBClusterSnapshot) SetStorageType(v string) *DBClusterSnapshot {
 	s.StorageType = &v
@@ -56787,8 +56823,7 @@ type RestoreDBInstanceFromDBSnapshotInput struct {
 	// This setting is required for RDS Custom.
 	CustomIamInstanceProfile *string `type:"string"`
 
-	// The identifier for the RDS for MySQL Multi-AZ DB cluster snapshot to restore
-	// from.
+	// The identifier for the Multi-AZ DB cluster snapshot to restore from.
 	//
 	// For more information on Multi-AZ DB clusters, see Multi-AZ DB cluster deployments
 	// (https://docs.aws.amazon.com/AmazonRDS/latest/UserGuide/multi-az-db-clusters-concepts.html)
@@ -56806,9 +56841,6 @@ type RestoreDBInstanceFromDBSnapshotInput struct {
 	//    the DBClusterSnapshotIdentifier must be the ARN of the shared snapshot.
 	//
 	//    * Can't be the identifier of an Aurora DB cluster snapshot.
-	//
-	//    * Can't be the identifier of an RDS for PostgreSQL Multi-AZ DB cluster
-	//    snapshot.
 	DBClusterSnapshotIdentifier *string `type:"string"`
 
 	// The compute and memory capacity of the Amazon RDS DB instance, for example