feat(client-kafka): Adds ControllerNodeInfo in ListNodes response to support Raft mode for MSK

Author: awstools

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

@@ -60,6 +60,11 @@ export interface ListNodesCommandOutput extends ListNodesResponse, __MetadataBea
  * //           "STRING_VALUE",
  * //         ],
  * //       },
+ * //       ControllerNodeInfo: { // ControllerNodeInfo
+ * //         Endpoints: [
+ * //           "STRING_VALUE",
+ * //         ],
+ * //       },
  * //       InstanceType: "STRING_VALUE",
  * //       NodeARN: "STRING_VALUE",
  * //       NodeType: "BROKER",

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

@@ -1675,6 +1675,18 @@ export interface BrokerNodeInfo {
   Endpoints?: string[];
 }
 
+/**
+ * <p>Controller node information.</p>
+ * @public
+ */
+export interface ControllerNodeInfo {
+  /**
+   * <p>Endpoints for accessing the Controller.</p>
+   * @public
+   */
+  Endpoints?: string[];
+}
+
 /**
  * @public
  * @enum
@@ -1741,6 +1753,12 @@ export interface NodeInfo {
    */
   BrokerNodeInfo?: BrokerNodeInfo;
 
+  /**
+   * <p>The ControllerNodeInfo.</p>
+   * @public
+   */
+  ControllerNodeInfo?: ControllerNodeInfo;
+
   /**
    * <p>The instance type.</p>
    * @public

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

@@ -183,6 +183,7 @@ import {
   ConnectivityInfo,
   ConsumerGroupReplication,
   ConsumerGroupReplicationUpdate,
+  ControllerNodeInfo,
   EBSStorageInfo,
   EncryptionAtRest,
   EncryptionInfo,
@@ -3816,6 +3817,15 @@ const de_ConsumerGroupReplication = (output: any, context: __SerdeContext): Cons
   }) as any;
 };
 
+/**
+ * deserializeAws_restJson1ControllerNodeInfo
+ */
+const de_ControllerNodeInfo = (output: any, context: __SerdeContext): ControllerNodeInfo => {
+  return take(output, {
+    Endpoints: [, _json, `endpoints`],
+  }) as any;
+};
+
 /**
  * deserializeAws_restJson1EBSStorageInfo
  */
@@ -3998,6 +4008,7 @@ const de_NodeInfo = (output: any, context: __SerdeContext): NodeInfo => {
   return take(output, {
     AddedToClusterTime: [, __expectString, `addedToClusterTime`],
     BrokerNodeInfo: [, (_: any) => de_BrokerNodeInfo(_, context), `brokerNodeInfo`],
+    ControllerNodeInfo: [, (_: any) => de_ControllerNodeInfo(_, context), `controllerNodeInfo`],
     InstanceType: [, __expectString, `instanceType`],
     NodeARN: [, __expectString, `nodeARN`],
     NodeType: [, __expectString, `nodeType`],

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

@@ -1523,6 +1523,21 @@
         "smithy.api#documentation": "<p>Details about consumer group replication.</p>"
       }
     },
+    "com.amazonaws.kafka#ControllerNodeInfo": {
+      "type": "structure",
+      "members": {
+        "Endpoints": {
+          "target": "com.amazonaws.kafka#__listOf__string",
+          "traits": {
+            "smithy.api#documentation": "<p>Endpoints for accessing the Controller.</p>",
+            "smithy.api#jsonName": "endpoints"
+          }
+        }
+      },
+      "traits": {
+        "smithy.api#documentation": "<p>Controller node information.</p>"
+      }
+    },
     "com.amazonaws.kafka#CreateCluster": {
       "type": "operation",
       "input": {
@@ -6461,6 +6476,13 @@
             "smithy.api#jsonName": "brokerNodeInfo"
           }
         },
+        "ControllerNodeInfo": {
+          "target": "com.amazonaws.kafka#ControllerNodeInfo",
+          "traits": {
+            "smithy.api#documentation": "<p>The ControllerNodeInfo.</p>",
+            "smithy.api#jsonName": "controllerNodeInfo"
+          }
+        },
         "InstanceType": {
           "target": "com.amazonaws.kafka#__string",
           "traits": {