Managed Streaming for Kafka Update: This release enables AWS MSK customers to list Apache Kafka versions that are supported on AWS MSK clusters. Also includes changes to expose additional details of a cluster's state in DescribeCluster and ListClusters APIs.

Author: AWS

.changes/next-release/feature-ManagedStreamingforKafka-8af9075.json

@@ -0,0 +1,5 @@
+{
+    "type": "feature",
+    "category": "Managed Streaming for Kafka",
+    "description": "This release enables AWS MSK customers to list Apache Kafka versions that are supported on AWS MSK clusters. Also includes changes to expose additional details of a cluster's state in DescribeCluster and ListClusters APIs."
+}

services/kafka/src/main/resources/codegen-resources/paginators-1.json

@@ -12,6 +12,12 @@
       "limit_key": "MaxResults",
       "result_key": "Configurations"
     },
+    "ListKafkaVersions": {
+      "input_token": "NextToken",
+      "output_token": "NextToken",
+      "limit_key": "MaxResults",
+      "result_key": "KafkaVersions"
+    },
     "ListNodes": {
       "input_token": "NextToken",
       "output_token": "NextToken",

services/kafka/src/main/resources/codegen-resources/service-2.json

@@ -483,6 +483,39 @@
       ],
       "documentation": "\n            <p>Returns a list of all the MSK configurations in this Region.</p>\n         "
     },
+    "ListKafkaVersions": {
+      "name": "ListKafkaVersions",
+      "http": {
+        "method": "GET",
+        "requestUri": "/v1/kafka-versions",
+        "responseCode": 200
+      },
+      "input": {
+        "shape": "ListKafkaVersionsRequest"
+      },
+      "output": {
+        "shape": "ListKafkaVersionsResponse"
+      },
+      "errors": [
+        {
+          "shape": "BadRequestException",
+          "documentation": "\n            <p>The request isn't valid because the input is incorrect. Correct your input and then submit it again.</p>\n         "
+        },
+        {
+          "shape": "UnauthorizedException",
+          "documentation": "\n            <p>The request is not authorized. The provided credentials couldn't be validated.</p>\n         "
+        },
+        {
+          "shape": "InternalServerErrorException",
+          "documentation": "\n            <p>There was an unexpected internal server error. Retrying your request might resolve the issue.</p>\n         "
+        },
+        {
+          "shape": "ForbiddenException",
+          "documentation": "\n            <p>Access forbidden. Check your credentials and then retry your request.</p>\n         "
+        }
+      ],
+      "documentation": "\n            <p>Returns a list of Kafka versions.</p>\n         "
+    },
     "ListNodes": {
       "name": "ListNodes",
       "http": {
@@ -978,6 +1011,10 @@
           "locationName": "state",
           "documentation": "\n            <p>The state of the cluster. The possible states are CREATING, ACTIVE, and FAILED.</p>\n         "
         },
+        "StateInfo" : {
+          "shape" : "StateInfo",
+          "locationName" : "stateInfo"
+        },
         "Tags": {
           "shape": "__mapOf__string",
           "locationName": "tags",
@@ -1653,6 +1690,26 @@
         "httpStatusCode": 500
       }
     },
+    "KafkaVersion": {
+      "type": "structure",
+      "members": {
+        "Version": {
+          "shape": "__string",
+          "locationName": "version"
+        },
+        "Status": {
+          "shape": "KafkaVersionStatus",
+          "locationName": "status"
+        }
+      }
+    },
+    "KafkaVersionStatus": {
+      "type": "string",
+      "enum": [
+        "ACTIVE",
+        "DEPRECATED"
+      ]
+    },
     "ListClusterOperationsRequest": {
       "type": "structure",
       "members": {
@@ -1805,6 +1862,36 @@
         }
       }
     },
+    "ListKafkaVersionsRequest": {
+      "type": "structure",
+      "members": {
+        "MaxResults": {
+          "shape": "MaxResults",
+          "location": "querystring",
+          "locationName": "maxResults",
+          "documentation": "\n            <p>The maximum number of results to return in the response. If there are more results, the response includes a NextToken parameter.</p>"
+        },
+        "NextToken": {
+          "shape": "__string",
+          "location": "querystring",
+          "locationName": "nextToken",
+          "documentation": "\n            <p>The paginated results marker. When the result of the operation is truncated, the call returns NextToken in the response. To get the next batch, provide this token in your next request.</p>"
+        }
+      }
+    },
+    "ListKafkaVersionsResponse": {
+      "type": "structure",
+      "members": {
+        "KafkaVersions": {
+          "shape": "__listOfKafkaVersion",
+          "locationName": "kafkaVersions"
+        },
+        "NextToken": {
+          "shape": "__string",
+          "locationName": "nextToken"
+        }
+      }
+    },
     "ListNodesRequest": {
       "type": "structure",
       "members": {
@@ -2093,6 +2180,19 @@
         "httpStatusCode": 503
       }
     },
+    "StateInfo" : {
+      "type" : "structure",
+      "members" : {
+        "Code" : {
+          "shape" : "__string",
+          "locationName" : "code"
+        },
+        "Message" : {
+          "shape" : "__string",
+          "locationName" : "message"
+        }
+      }
+    },
     "StorageInfo": {
       "type": "structure",
       "members": {
@@ -2445,6 +2545,12 @@
         "shape": "ConfigurationRevision"
       }
     },
+    "__listOfKafkaVersion": {
+      "type": "list",
+      "member": {
+        "shape": "KafkaVersion"
+      }
+    },
     "__listOfNodeInfo": {
       "type": "list",
       "member": {
@@ -2493,4 +2599,4 @@
     }
   },
   "documentation": "\n               <p>The operations for managing an Amazon MSK cluster.</p>\n            "
-}
+}