File Explorer

/var/runtime/node_modules/@aws-sdk/client-kafka/dist-cjs
This explorer reads the filesystem of the server it runs on, so /workspace/user isn't present here. Browsing and the terminal still work against this server's own disk from /.
2 dirs
3 files
index.js191 KB · 4336 lines
1"use strict";2var __defProp = Object.defineProperty;3var __getOwnPropDesc = Object.getOwnPropertyDescriptor;4var __getOwnPropNames = Object.getOwnPropertyNames;5var __hasOwnProp = Object.prototype.hasOwnProperty;6var __name = (target, value) => __defProp(target, "name", { value, configurable: true });7var __export = (target, all) => {8  for (var name in all)9    __defProp(target, name, { get: all[name], enumerable: true });10};11var __copyProps = (to, from, except, desc) => {12  if (from && typeof from === "object" || typeof from === "function") {13    for (let key of __getOwnPropNames(from))14      if (!__hasOwnProp.call(to, key) && key !== except)15        __defProp(to, key, { get: () => from[key], enumerable: !(desc = __getOwnPropDesc(from, key)) || desc.enumerable });16  }17  return to;18};19var __toCommonJS = (mod) => __copyProps(__defProp({}, "__esModule", { value: true }), mod);20 21// src/index.ts22var index_exports = {};23__export(index_exports, {24  BadRequestException: () => BadRequestException,25  BatchAssociateScramSecretCommand: () => BatchAssociateScramSecretCommand,26  BatchDisassociateScramSecretCommand: () => BatchDisassociateScramSecretCommand,27  BrokerAZDistribution: () => BrokerAZDistribution,28  ClientBroker: () => ClientBroker,29  ClusterState: () => ClusterState,30  ClusterType: () => ClusterType,31  ConfigurationState: () => ConfigurationState,32  ConflictException: () => ConflictException,33  CreateClusterCommand: () => CreateClusterCommand,34  CreateClusterV2Command: () => CreateClusterV2Command,35  CreateConfigurationCommand: () => CreateConfigurationCommand,36  CreateReplicatorCommand: () => CreateReplicatorCommand,37  CreateVpcConnectionCommand: () => CreateVpcConnectionCommand,38  CustomerActionStatus: () => CustomerActionStatus,39  DeleteClusterCommand: () => DeleteClusterCommand,40  DeleteClusterPolicyCommand: () => DeleteClusterPolicyCommand,41  DeleteConfigurationCommand: () => DeleteConfigurationCommand,42  DeleteReplicatorCommand: () => DeleteReplicatorCommand,43  DeleteVpcConnectionCommand: () => DeleteVpcConnectionCommand,44  DescribeClusterCommand: () => DescribeClusterCommand,45  DescribeClusterOperationCommand: () => DescribeClusterOperationCommand,46  DescribeClusterOperationV2Command: () => DescribeClusterOperationV2Command,47  DescribeClusterV2Command: () => DescribeClusterV2Command,48  DescribeConfigurationCommand: () => DescribeConfigurationCommand,49  DescribeConfigurationRevisionCommand: () => DescribeConfigurationRevisionCommand,50  DescribeReplicatorCommand: () => DescribeReplicatorCommand,51  DescribeVpcConnectionCommand: () => DescribeVpcConnectionCommand,52  EnhancedMonitoring: () => EnhancedMonitoring,53  ForbiddenException: () => ForbiddenException,54  GetBootstrapBrokersCommand: () => GetBootstrapBrokersCommand,55  GetClusterPolicyCommand: () => GetClusterPolicyCommand,56  GetCompatibleKafkaVersionsCommand: () => GetCompatibleKafkaVersionsCommand,57  InternalServerErrorException: () => InternalServerErrorException,58  Kafka: () => Kafka,59  KafkaClient: () => KafkaClient,60  KafkaServiceException: () => KafkaServiceException,61  KafkaVersionStatus: () => KafkaVersionStatus,62  ListClientVpcConnectionsCommand: () => ListClientVpcConnectionsCommand,63  ListClusterOperationsCommand: () => ListClusterOperationsCommand,64  ListClusterOperationsV2Command: () => ListClusterOperationsV2Command,65  ListClustersCommand: () => ListClustersCommand,66  ListClustersV2Command: () => ListClustersV2Command,67  ListConfigurationRevisionsCommand: () => ListConfigurationRevisionsCommand,68  ListConfigurationsCommand: () => ListConfigurationsCommand,69  ListKafkaVersionsCommand: () => ListKafkaVersionsCommand,70  ListNodesCommand: () => ListNodesCommand,71  ListReplicatorsCommand: () => ListReplicatorsCommand,72  ListScramSecretsCommand: () => ListScramSecretsCommand,73  ListTagsForResourceCommand: () => ListTagsForResourceCommand,74  ListVpcConnectionsCommand: () => ListVpcConnectionsCommand,75  NodeType: () => NodeType,76  NotFoundException: () => NotFoundException,77  PutClusterPolicyCommand: () => PutClusterPolicyCommand,78  RebootBrokerCommand: () => RebootBrokerCommand,79  RejectClientVpcConnectionCommand: () => RejectClientVpcConnectionCommand,80  ReplicationStartingPositionType: () => ReplicationStartingPositionType,81  ReplicationTopicNameConfigurationType: () => ReplicationTopicNameConfigurationType,82  ReplicatorState: () => ReplicatorState,83  ServiceUnavailableException: () => ServiceUnavailableException,84  StorageMode: () => StorageMode,85  TagResourceCommand: () => TagResourceCommand,86  TargetCompressionType: () => TargetCompressionType,87  TooManyRequestsException: () => TooManyRequestsException,88  UnauthorizedException: () => UnauthorizedException,89  UntagResourceCommand: () => UntagResourceCommand,90  UpdateBrokerCountCommand: () => UpdateBrokerCountCommand,91  UpdateBrokerStorageCommand: () => UpdateBrokerStorageCommand,92  UpdateBrokerTypeCommand: () => UpdateBrokerTypeCommand,93  UpdateClusterConfigurationCommand: () => UpdateClusterConfigurationCommand,94  UpdateClusterKafkaVersionCommand: () => UpdateClusterKafkaVersionCommand,95  UpdateConfigurationCommand: () => UpdateConfigurationCommand,96  UpdateConnectivityCommand: () => UpdateConnectivityCommand,97  UpdateMonitoringCommand: () => UpdateMonitoringCommand,98  UpdateReplicationInfoCommand: () => UpdateReplicationInfoCommand,99  UpdateSecurityCommand: () => UpdateSecurityCommand,100  UpdateStorageCommand: () => UpdateStorageCommand,101  UserIdentityType: () => UserIdentityType,102  VpcConnectionState: () => VpcConnectionState,103  __Client: () => import_smithy_client.Client,104  paginateListClientVpcConnections: () => paginateListClientVpcConnections,105  paginateListClusterOperations: () => paginateListClusterOperations,106  paginateListClusterOperationsV2: () => paginateListClusterOperationsV2,107  paginateListClusters: () => paginateListClusters,108  paginateListClustersV2: () => paginateListClustersV2,109  paginateListConfigurationRevisions: () => paginateListConfigurationRevisions,110  paginateListConfigurations: () => paginateListConfigurations,111  paginateListKafkaVersions: () => paginateListKafkaVersions,112  paginateListNodes: () => paginateListNodes,113  paginateListReplicators: () => paginateListReplicators,114  paginateListScramSecrets: () => paginateListScramSecrets,115  paginateListVpcConnections: () => paginateListVpcConnections116});117module.exports = __toCommonJS(index_exports);118 119// src/KafkaClient.ts120var import_middleware_host_header = require("@aws-sdk/middleware-host-header");121var import_middleware_logger = require("@aws-sdk/middleware-logger");122var import_middleware_recursion_detection = require("@aws-sdk/middleware-recursion-detection");123var import_middleware_user_agent = require("@aws-sdk/middleware-user-agent");124var import_config_resolver = require("@smithy/config-resolver");125var import_core = require("@smithy/core");126var import_middleware_content_length = require("@smithy/middleware-content-length");127var import_middleware_endpoint = require("@smithy/middleware-endpoint");128var import_middleware_retry = require("@smithy/middleware-retry");129 130var import_httpAuthSchemeProvider = require("./auth/httpAuthSchemeProvider");131 132// src/endpoint/EndpointParameters.ts133var resolveClientEndpointParameters = /* @__PURE__ */ __name((options) => {134  return Object.assign(options, {135    useDualstackEndpoint: options.useDualstackEndpoint ?? false,136    useFipsEndpoint: options.useFipsEndpoint ?? false,137    defaultSigningName: "kafka"138  });139}, "resolveClientEndpointParameters");140var commonParams = {141  UseFIPS: { type: "builtInParams", name: "useFipsEndpoint" },142  Endpoint: { type: "builtInParams", name: "endpoint" },143  Region: { type: "builtInParams", name: "region" },144  UseDualStack: { type: "builtInParams", name: "useDualstackEndpoint" }145};146 147// src/KafkaClient.ts148var import_runtimeConfig = require("././runtimeConfig");149 150// src/runtimeExtensions.ts151var import_region_config_resolver = require("@aws-sdk/region-config-resolver");152var import_protocol_http = require("@smithy/protocol-http");153var import_smithy_client = require("@smithy/smithy-client");154 155// src/auth/httpAuthExtensionConfiguration.ts156var getHttpAuthExtensionConfiguration = /* @__PURE__ */ __name((runtimeConfig) => {157  const _httpAuthSchemes = runtimeConfig.httpAuthSchemes;158  let _httpAuthSchemeProvider = runtimeConfig.httpAuthSchemeProvider;159  let _credentials = runtimeConfig.credentials;160  return {161    setHttpAuthScheme(httpAuthScheme) {162      const index = _httpAuthSchemes.findIndex((scheme) => scheme.schemeId === httpAuthScheme.schemeId);163      if (index === -1) {164        _httpAuthSchemes.push(httpAuthScheme);165      } else {166        _httpAuthSchemes.splice(index, 1, httpAuthScheme);167      }168    },169    httpAuthSchemes() {170      return _httpAuthSchemes;171    },172    setHttpAuthSchemeProvider(httpAuthSchemeProvider) {173      _httpAuthSchemeProvider = httpAuthSchemeProvider;174    },175    httpAuthSchemeProvider() {176      return _httpAuthSchemeProvider;177    },178    setCredentials(credentials) {179      _credentials = credentials;180    },181    credentials() {182      return _credentials;183    }184  };185}, "getHttpAuthExtensionConfiguration");186var resolveHttpAuthRuntimeConfig = /* @__PURE__ */ __name((config) => {187  return {188    httpAuthSchemes: config.httpAuthSchemes(),189    httpAuthSchemeProvider: config.httpAuthSchemeProvider(),190    credentials: config.credentials()191  };192}, "resolveHttpAuthRuntimeConfig");193 194// src/runtimeExtensions.ts195var resolveRuntimeExtensions = /* @__PURE__ */ __name((runtimeConfig, extensions) => {196  const extensionConfiguration = Object.assign(197    (0, import_region_config_resolver.getAwsRegionExtensionConfiguration)(runtimeConfig),198    (0, import_smithy_client.getDefaultExtensionConfiguration)(runtimeConfig),199    (0, import_protocol_http.getHttpHandlerExtensionConfiguration)(runtimeConfig),200    getHttpAuthExtensionConfiguration(runtimeConfig)201  );202  extensions.forEach((extension) => extension.configure(extensionConfiguration));203  return Object.assign(204    runtimeConfig,205    (0, import_region_config_resolver.resolveAwsRegionExtensionConfiguration)(extensionConfiguration),206    (0, import_smithy_client.resolveDefaultRuntimeConfig)(extensionConfiguration),207    (0, import_protocol_http.resolveHttpHandlerRuntimeConfig)(extensionConfiguration),208    resolveHttpAuthRuntimeConfig(extensionConfiguration)209  );210}, "resolveRuntimeExtensions");211 212// src/KafkaClient.ts213var KafkaClient = class extends import_smithy_client.Client {214  static {215    __name(this, "KafkaClient");216  }217  /**218   * The resolved configuration of KafkaClient class. This is resolved and normalized from the {@link KafkaClientConfig | constructor configuration interface}.219   */220  config;221  constructor(...[configuration]) {222    const _config_0 = (0, import_runtimeConfig.getRuntimeConfig)(configuration || {});223    super(_config_0);224    this.initConfig = _config_0;225    const _config_1 = resolveClientEndpointParameters(_config_0);226    const _config_2 = (0, import_middleware_user_agent.resolveUserAgentConfig)(_config_1);227    const _config_3 = (0, import_middleware_retry.resolveRetryConfig)(_config_2);228    const _config_4 = (0, import_config_resolver.resolveRegionConfig)(_config_3);229    const _config_5 = (0, import_middleware_host_header.resolveHostHeaderConfig)(_config_4);230    const _config_6 = (0, import_middleware_endpoint.resolveEndpointConfig)(_config_5);231    const _config_7 = (0, import_httpAuthSchemeProvider.resolveHttpAuthSchemeConfig)(_config_6);232    const _config_8 = resolveRuntimeExtensions(_config_7, configuration?.extensions || []);233    this.config = _config_8;234    this.middlewareStack.use((0, import_middleware_user_agent.getUserAgentPlugin)(this.config));235    this.middlewareStack.use((0, import_middleware_retry.getRetryPlugin)(this.config));236    this.middlewareStack.use((0, import_middleware_content_length.getContentLengthPlugin)(this.config));237    this.middlewareStack.use((0, import_middleware_host_header.getHostHeaderPlugin)(this.config));238    this.middlewareStack.use((0, import_middleware_logger.getLoggerPlugin)(this.config));239    this.middlewareStack.use((0, import_middleware_recursion_detection.getRecursionDetectionPlugin)(this.config));240    this.middlewareStack.use(241      (0, import_core.getHttpAuthSchemeEndpointRuleSetPlugin)(this.config, {242        httpAuthSchemeParametersProvider: import_httpAuthSchemeProvider.defaultKafkaHttpAuthSchemeParametersProvider,243        identityProviderConfigProvider: /* @__PURE__ */ __name(async (config) => new import_core.DefaultIdentityProviderConfig({244          "aws.auth#sigv4": config.credentials245        }), "identityProviderConfigProvider")246      })247    );248    this.middlewareStack.use((0, import_core.getHttpSigningPlugin)(this.config));249  }250  /**251   * Destroy underlying resources, like sockets. It's usually not necessary to do this.252   * However in Node.js, it's best to explicitly shut down the client's agent when it is no longer needed.253   * Otherwise, sockets might stay open for quite a long time before the server terminates them.254   */255  destroy() {256    super.destroy();257  }258};259 260// src/Kafka.ts261 262 263// src/commands/BatchAssociateScramSecretCommand.ts264 265var import_middleware_serde = require("@smithy/middleware-serde");266 267 268// src/protocols/Aws_restJson1.ts269var import_core2 = require("@aws-sdk/core");270 271 272 273// src/models/KafkaServiceException.ts274 275var KafkaServiceException = class _KafkaServiceException extends import_smithy_client.ServiceException {276  static {277    __name(this, "KafkaServiceException");278  }279  /**280   * @internal281   */282  constructor(options) {283    super(options);284    Object.setPrototypeOf(this, _KafkaServiceException.prototype);285  }286};287 288// src/models/models_0.ts289var VpcConnectionState = {290  AVAILABLE: "AVAILABLE",291  CREATING: "CREATING",292  DEACTIVATING: "DEACTIVATING",293  DELETING: "DELETING",294  FAILED: "FAILED",295  INACTIVE: "INACTIVE",296  REJECTED: "REJECTED",297  REJECTING: "REJECTING"298};299var ClusterType = {300  PROVISIONED: "PROVISIONED",301  SERVERLESS: "SERVERLESS"302};303var BrokerAZDistribution = {304  DEFAULT: "DEFAULT"305};306var CustomerActionStatus = {307  ACTION_RECOMMENDED: "ACTION_RECOMMENDED",308  CRITICAL_ACTION_REQUIRED: "CRITICAL_ACTION_REQUIRED",309  NONE: "NONE"310};311var ClientBroker = {312  PLAINTEXT: "PLAINTEXT",313  TLS: "TLS",314  TLS_PLAINTEXT: "TLS_PLAINTEXT"315};316var EnhancedMonitoring = {317  DEFAULT: "DEFAULT",318  PER_BROKER: "PER_BROKER",319  PER_TOPIC_PER_BROKER: "PER_TOPIC_PER_BROKER",320  PER_TOPIC_PER_PARTITION: "PER_TOPIC_PER_PARTITION"321};322var StorageMode = {323  LOCAL: "LOCAL",324  TIERED: "TIERED"325};326var ClusterState = {327  ACTIVE: "ACTIVE",328  CREATING: "CREATING",329  DELETING: "DELETING",330  FAILED: "FAILED",331  HEALING: "HEALING",332  MAINTENANCE: "MAINTENANCE",333  REBOOTING_BROKER: "REBOOTING_BROKER",334  UPDATING: "UPDATING"335};336var UserIdentityType = {337  AWSACCOUNT: "AWSACCOUNT",338  AWSSERVICE: "AWSSERVICE"339};340var ConfigurationState = {341  ACTIVE: "ACTIVE",342  DELETE_FAILED: "DELETE_FAILED",343  DELETING: "DELETING"344};345var KafkaVersionStatus = {346  ACTIVE: "ACTIVE",347  DEPRECATED: "DEPRECATED"348};349var NodeType = {350  BROKER: "BROKER"351};352var TargetCompressionType = {353  GZIP: "GZIP",354  LZ4: "LZ4",355  NONE: "NONE",356  SNAPPY: "SNAPPY",357  ZSTD: "ZSTD"358};359var ReplicationStartingPositionType = {360  EARLIEST: "EARLIEST",361  LATEST: "LATEST"362};363var ReplicationTopicNameConfigurationType = {364  IDENTICAL: "IDENTICAL",365  PREFIXED_WITH_SOURCE_CLUSTER_ALIAS: "PREFIXED_WITH_SOURCE_CLUSTER_ALIAS"366};367var ReplicatorState = {368  CREATING: "CREATING",369  DELETING: "DELETING",370  FAILED: "FAILED",371  RUNNING: "RUNNING",372  UPDATING: "UPDATING"373};374var BadRequestException = class _BadRequestException extends KafkaServiceException {375  static {376    __name(this, "BadRequestException");377  }378  name = "BadRequestException";379  $fault = "client";380  /**381   * <p>The parameter that caused the error.</p>382   * @public383   */384  InvalidParameter;385  /**386   * <p>The description of the error.</p>387   * @public388   */389  Message;390  /**391   * @internal392   */393  constructor(opts) {394    super({395      name: "BadRequestException",396      $fault: "client",397      ...opts398    });399    Object.setPrototypeOf(this, _BadRequestException.prototype);400    this.InvalidParameter = opts.InvalidParameter;401    this.Message = opts.Message;402  }403};404var ForbiddenException = class _ForbiddenException extends KafkaServiceException {405  static {406    __name(this, "ForbiddenException");407  }408  name = "ForbiddenException";409  $fault = "client";410  /**411   * <p>The parameter that caused the error.</p>412   * @public413   */414  InvalidParameter;415  /**416   * <p>The description of the error.</p>417   * @public418   */419  Message;420  /**421   * @internal422   */423  constructor(opts) {424    super({425      name: "ForbiddenException",426      $fault: "client",427      ...opts428    });429    Object.setPrototypeOf(this, _ForbiddenException.prototype);430    this.InvalidParameter = opts.InvalidParameter;431    this.Message = opts.Message;432  }433};434var InternalServerErrorException = class _InternalServerErrorException extends KafkaServiceException {435  static {436    __name(this, "InternalServerErrorException");437  }438  name = "InternalServerErrorException";439  $fault = "server";440  /**441   * <p>The parameter that caused the error.</p>442   * @public443   */444  InvalidParameter;445  /**446   * <p>The description of the error.</p>447   * @public448   */449  Message;450  /**451   * @internal452   */453  constructor(opts) {454    super({455      name: "InternalServerErrorException",456      $fault: "server",457      ...opts458    });459    Object.setPrototypeOf(this, _InternalServerErrorException.prototype);460    this.InvalidParameter = opts.InvalidParameter;461    this.Message = opts.Message;462  }463};464var NotFoundException = class _NotFoundException extends KafkaServiceException {465  static {466    __name(this, "NotFoundException");467  }468  name = "NotFoundException";469  $fault = "client";470  /**471   * <p>The parameter that caused the error.</p>472   * @public473   */474  InvalidParameter;475  /**476   * <p>The description of the error.</p>477   * @public478   */479  Message;480  /**481   * @internal482   */483  constructor(opts) {484    super({485      name: "NotFoundException",486      $fault: "client",487      ...opts488    });489    Object.setPrototypeOf(this, _NotFoundException.prototype);490    this.InvalidParameter = opts.InvalidParameter;491    this.Message = opts.Message;492  }493};494var ServiceUnavailableException = class _ServiceUnavailableException extends KafkaServiceException {495  static {496    __name(this, "ServiceUnavailableException");497  }498  name = "ServiceUnavailableException";499  $fault = "server";500  /**501   * <p>The parameter that caused the error.</p>502   * @public503   */504  InvalidParameter;505  /**506   * <p>The description of the error.</p>507   * @public508   */509  Message;510  /**511   * @internal512   */513  constructor(opts) {514    super({515      name: "ServiceUnavailableException",516      $fault: "server",517      ...opts518    });519    Object.setPrototypeOf(this, _ServiceUnavailableException.prototype);520    this.InvalidParameter = opts.InvalidParameter;521    this.Message = opts.Message;522  }523};524var TooManyRequestsException = class _TooManyRequestsException extends KafkaServiceException {525  static {526    __name(this, "TooManyRequestsException");527  }528  name = "TooManyRequestsException";529  $fault = "client";530  /**531   * <p>The parameter that caused the error.</p>532   * @public533   */534  InvalidParameter;535  /**536   * <p>The description of the error.</p>537   * @public538   */539  Message;540  /**541   * @internal542   */543  constructor(opts) {544    super({545      name: "TooManyRequestsException",546      $fault: "client",547      ...opts548    });549    Object.setPrototypeOf(this, _TooManyRequestsException.prototype);550    this.InvalidParameter = opts.InvalidParameter;551    this.Message = opts.Message;552  }553};554var UnauthorizedException = class _UnauthorizedException extends KafkaServiceException {555  static {556    __name(this, "UnauthorizedException");557  }558  name = "UnauthorizedException";559  $fault = "client";560  /**561   * <p>The parameter that caused the error.</p>562   * @public563   */564  InvalidParameter;565  /**566   * <p>The description of the error.</p>567   * @public568   */569  Message;570  /**571   * @internal572   */573  constructor(opts) {574    super({575      name: "UnauthorizedException",576      $fault: "client",577      ...opts578    });579    Object.setPrototypeOf(this, _UnauthorizedException.prototype);580    this.InvalidParameter = opts.InvalidParameter;581    this.Message = opts.Message;582  }583};584var ConflictException = class _ConflictException extends KafkaServiceException {585  static {586    __name(this, "ConflictException");587  }588  name = "ConflictException";589  $fault = "client";590  /**591   * <p>The parameter that caused the error.</p>592   * @public593   */594  InvalidParameter;595  /**596   * <p>The description of the error.</p>597   * @public598   */599  Message;600  /**601   * @internal602   */603  constructor(opts) {604    super({605      name: "ConflictException",606      $fault: "client",607      ...opts608    });609    Object.setPrototypeOf(this, _ConflictException.prototype);610    this.InvalidParameter = opts.InvalidParameter;611    this.Message = opts.Message;612  }613};614 615// src/protocols/Aws_restJson1.ts616var se_BatchAssociateScramSecretCommand = /* @__PURE__ */ __name(async (input, context) => {617  const b = (0, import_core.requestBuilder)(input, context);618  const headers = {619    "content-type": "application/json"620  };621  b.bp("/v1/clusters/{ClusterArn}/scram-secrets");622  b.p("ClusterArn", () => input.ClusterArn, "{ClusterArn}", false);623  let body;624  body = JSON.stringify(625    (0, import_smithy_client.take)(input, {626      secretArnList: [, (_) => (0, import_smithy_client._json)(_), `SecretArnList`]627    })628  );629  b.m("POST").h(headers).b(body);630  return b.build();631}, "se_BatchAssociateScramSecretCommand");632var se_BatchDisassociateScramSecretCommand = /* @__PURE__ */ __name(async (input, context) => {633  const b = (0, import_core.requestBuilder)(input, context);634  const headers = {635    "content-type": "application/json"636  };637  b.bp("/v1/clusters/{ClusterArn}/scram-secrets");638  b.p("ClusterArn", () => input.ClusterArn, "{ClusterArn}", false);639  let body;640  body = JSON.stringify(641    (0, import_smithy_client.take)(input, {642      secretArnList: [, (_) => (0, import_smithy_client._json)(_), `SecretArnList`]643    })644  );645  b.m("PATCH").h(headers).b(body);646  return b.build();647}, "se_BatchDisassociateScramSecretCommand");648var se_CreateClusterCommand = /* @__PURE__ */ __name(async (input, context) => {649  const b = (0, import_core.requestBuilder)(input, context);650  const headers = {651    "content-type": "application/json"652  };653  b.bp("/v1/clusters");654  let body;655  body = JSON.stringify(656    (0, import_smithy_client.take)(input, {657      brokerNodeGroupInfo: [, (_) => se_BrokerNodeGroupInfo(_, context), `BrokerNodeGroupInfo`],658      clientAuthentication: [, (_) => se_ClientAuthentication(_, context), `ClientAuthentication`],659      clusterName: [, , `ClusterName`],660      configurationInfo: [, (_) => se_ConfigurationInfo(_, context), `ConfigurationInfo`],661      encryptionInfo: [, (_) => se_EncryptionInfo(_, context), `EncryptionInfo`],662      enhancedMonitoring: [, , `EnhancedMonitoring`],663      kafkaVersion: [, , `KafkaVersion`],664      loggingInfo: [, (_) => se_LoggingInfo(_, context), `LoggingInfo`],665      numberOfBrokerNodes: [, , `NumberOfBrokerNodes`],666      openMonitoring: [, (_) => se_OpenMonitoringInfo(_, context), `OpenMonitoring`],667      storageMode: [, , `StorageMode`],668      tags: [, (_) => (0, import_smithy_client._json)(_), `Tags`]669    })670  );671  b.m("POST").h(headers).b(body);672  return b.build();673}, "se_CreateClusterCommand");674var se_CreateClusterV2Command = /* @__PURE__ */ __name(async (input, context) => {675  const b = (0, import_core.requestBuilder)(input, context);676  const headers = {677    "content-type": "application/json"678  };679  b.bp("/api/v2/clusters");680  let body;681  body = JSON.stringify(682    (0, import_smithy_client.take)(input, {683      clusterName: [, , `ClusterName`],684      provisioned: [, (_) => se_ProvisionedRequest(_, context), `Provisioned`],685      serverless: [, (_) => se_ServerlessRequest(_, context), `Serverless`],686      tags: [, (_) => (0, import_smithy_client._json)(_), `Tags`]687    })688  );689  b.m("POST").h(headers).b(body);690  return b.build();691}, "se_CreateClusterV2Command");692var se_CreateConfigurationCommand = /* @__PURE__ */ __name(async (input, context) => {693  const b = (0, import_core.requestBuilder)(input, context);694  const headers = {695    "content-type": "application/json"696  };697  b.bp("/v1/configurations");698  let body;699  body = JSON.stringify(700    (0, import_smithy_client.take)(input, {701      description: [, , `Description`],702      kafkaVersions: [, (_) => (0, import_smithy_client._json)(_), `KafkaVersions`],703      name: [, , `Name`],704      serverProperties: [, (_) => context.base64Encoder(_), `ServerProperties`]705    })706  );707  b.m("POST").h(headers).b(body);708  return b.build();709}, "se_CreateConfigurationCommand");710var se_CreateReplicatorCommand = /* @__PURE__ */ __name(async (input, context) => {711  const b = (0, import_core.requestBuilder)(input, context);712  const headers = {713    "content-type": "application/json"714  };715  b.bp("/replication/v1/replicators");716  let body;717  body = JSON.stringify(718    (0, import_smithy_client.take)(input, {719      description: [, , `Description`],720      kafkaClusters: [, (_) => se___listOfKafkaCluster(_, context), `KafkaClusters`],721      replicationInfoList: [, (_) => se___listOfReplicationInfo(_, context), `ReplicationInfoList`],722      replicatorName: [, , `ReplicatorName`],723      serviceExecutionRoleArn: [, , `ServiceExecutionRoleArn`],724      tags: [, (_) => (0, import_smithy_client._json)(_), `Tags`]725    })726  );727  b.m("POST").h(headers).b(body);728  return b.build();729}, "se_CreateReplicatorCommand");730var se_CreateVpcConnectionCommand = /* @__PURE__ */ __name(async (input, context) => {731  const b = (0, import_core.requestBuilder)(input, context);732  const headers = {733    "content-type": "application/json"734  };735  b.bp("/v1/vpc-connection");736  let body;737  body = JSON.stringify(738    (0, import_smithy_client.take)(input, {739      authentication: [, , `Authentication`],740      clientSubnets: [, (_) => (0, import_smithy_client._json)(_), `ClientSubnets`],741      securityGroups: [, (_) => (0, import_smithy_client._json)(_), `SecurityGroups`],742      tags: [, (_) => (0, import_smithy_client._json)(_), `Tags`],743      targetClusterArn: [, , `TargetClusterArn`],744      vpcId: [, , `VpcId`]745    })746  );747  b.m("POST").h(headers).b(body);748  return b.build();749}, "se_CreateVpcConnectionCommand");750var se_DeleteClusterCommand = /* @__PURE__ */ __name(async (input, context) => {751  const b = (0, import_core.requestBuilder)(input, context);752  const headers = {};753  b.bp("/v1/clusters/{ClusterArn}");754  b.p("ClusterArn", () => input.ClusterArn, "{ClusterArn}", false);755  const query = (0, import_smithy_client.map)({756    [_cV]: [, input[_CV]]757  });758  let body;759  b.m("DELETE").h(headers).q(query).b(body);760  return b.build();761}, "se_DeleteClusterCommand");762var se_DeleteClusterPolicyCommand = /* @__PURE__ */ __name(async (input, context) => {763  const b = (0, import_core.requestBuilder)(input, context);764  const headers = {};765  b.bp("/v1/clusters/{ClusterArn}/policy");766  b.p("ClusterArn", () => input.ClusterArn, "{ClusterArn}", false);767  let body;768  b.m("DELETE").h(headers).b(body);769  return b.build();770}, "se_DeleteClusterPolicyCommand");771var se_DeleteConfigurationCommand = /* @__PURE__ */ __name(async (input, context) => {772  const b = (0, import_core.requestBuilder)(input, context);773  const headers = {};774  b.bp("/v1/configurations/{Arn}");775  b.p("Arn", () => input.Arn, "{Arn}", false);776  let body;777  b.m("DELETE").h(headers).b(body);778  return b.build();779}, "se_DeleteConfigurationCommand");780var se_DeleteReplicatorCommand = /* @__PURE__ */ __name(async (input, context) => {781  const b = (0, import_core.requestBuilder)(input, context);782  const headers = {};783  b.bp("/replication/v1/replicators/{ReplicatorArn}");784  b.p("ReplicatorArn", () => input.ReplicatorArn, "{ReplicatorArn}", false);785  const query = (0, import_smithy_client.map)({786    [_cV]: [, input[_CV]]787  });788  let body;789  b.m("DELETE").h(headers).q(query).b(body);790  return b.build();791}, "se_DeleteReplicatorCommand");792var se_DeleteVpcConnectionCommand = /* @__PURE__ */ __name(async (input, context) => {793  const b = (0, import_core.requestBuilder)(input, context);794  const headers = {};795  b.bp("/v1/vpc-connection/{Arn}");796  b.p("Arn", () => input.Arn, "{Arn}", false);797  let body;798  b.m("DELETE").h(headers).b(body);799  return b.build();800}, "se_DeleteVpcConnectionCommand");801var se_DescribeClusterCommand = /* @__PURE__ */ __name(async (input, context) => {802  const b = (0, import_core.requestBuilder)(input, context);803  const headers = {};804  b.bp("/v1/clusters/{ClusterArn}");805  b.p("ClusterArn", () => input.ClusterArn, "{ClusterArn}", false);806  let body;807  b.m("GET").h(headers).b(body);808  return b.build();809}, "se_DescribeClusterCommand");810var se_DescribeClusterOperationCommand = /* @__PURE__ */ __name(async (input, context) => {811  const b = (0, import_core.requestBuilder)(input, context);812  const headers = {};813  b.bp("/v1/operations/{ClusterOperationArn}");814  b.p("ClusterOperationArn", () => input.ClusterOperationArn, "{ClusterOperationArn}", false);815  let body;816  b.m("GET").h(headers).b(body);817  return b.build();818}, "se_DescribeClusterOperationCommand");819var se_DescribeClusterOperationV2Command = /* @__PURE__ */ __name(async (input, context) => {820  const b = (0, import_core.requestBuilder)(input, context);821  const headers = {};822  b.bp("/api/v2/operations/{ClusterOperationArn}");823  b.p("ClusterOperationArn", () => input.ClusterOperationArn, "{ClusterOperationArn}", false);824  let body;825  b.m("GET").h(headers).b(body);826  return b.build();827}, "se_DescribeClusterOperationV2Command");828var se_DescribeClusterV2Command = /* @__PURE__ */ __name(async (input, context) => {829  const b = (0, import_core.requestBuilder)(input, context);830  const headers = {};831  b.bp("/api/v2/clusters/{ClusterArn}");832  b.p("ClusterArn", () => input.ClusterArn, "{ClusterArn}", false);833  let body;834  b.m("GET").h(headers).b(body);835  return b.build();836}, "se_DescribeClusterV2Command");837var se_DescribeConfigurationCommand = /* @__PURE__ */ __name(async (input, context) => {838  const b = (0, import_core.requestBuilder)(input, context);839  const headers = {};840  b.bp("/v1/configurations/{Arn}");841  b.p("Arn", () => input.Arn, "{Arn}", false);842  let body;843  b.m("GET").h(headers).b(body);844  return b.build();845}, "se_DescribeConfigurationCommand");846var se_DescribeConfigurationRevisionCommand = /* @__PURE__ */ __name(async (input, context) => {847  const b = (0, import_core.requestBuilder)(input, context);848  const headers = {};849  b.bp("/v1/configurations/{Arn}/revisions/{Revision}");850  b.p("Arn", () => input.Arn, "{Arn}", false);851  b.p("Revision", () => input.Revision.toString(), "{Revision}", false);852  let body;853  b.m("GET").h(headers).b(body);854  return b.build();855}, "se_DescribeConfigurationRevisionCommand");856var se_DescribeReplicatorCommand = /* @__PURE__ */ __name(async (input, context) => {857  const b = (0, import_core.requestBuilder)(input, context);858  const headers = {};859  b.bp("/replication/v1/replicators/{ReplicatorArn}");860  b.p("ReplicatorArn", () => input.ReplicatorArn, "{ReplicatorArn}", false);861  let body;862  b.m("GET").h(headers).b(body);863  return b.build();864}, "se_DescribeReplicatorCommand");865var se_DescribeVpcConnectionCommand = /* @__PURE__ */ __name(async (input, context) => {866  const b = (0, import_core.requestBuilder)(input, context);867  const headers = {};868  b.bp("/v1/vpc-connection/{Arn}");869  b.p("Arn", () => input.Arn, "{Arn}", false);870  let body;871  b.m("GET").h(headers).b(body);872  return b.build();873}, "se_DescribeVpcConnectionCommand");874var se_GetBootstrapBrokersCommand = /* @__PURE__ */ __name(async (input, context) => {875  const b = (0, import_core.requestBuilder)(input, context);876  const headers = {};877  b.bp("/v1/clusters/{ClusterArn}/bootstrap-brokers");878  b.p("ClusterArn", () => input.ClusterArn, "{ClusterArn}", false);879  let body;880  b.m("GET").h(headers).b(body);881  return b.build();882}, "se_GetBootstrapBrokersCommand");883var se_GetClusterPolicyCommand = /* @__PURE__ */ __name(async (input, context) => {884  const b = (0, import_core.requestBuilder)(input, context);885  const headers = {};886  b.bp("/v1/clusters/{ClusterArn}/policy");887  b.p("ClusterArn", () => input.ClusterArn, "{ClusterArn}", false);888  let body;889  b.m("GET").h(headers).b(body);890  return b.build();891}, "se_GetClusterPolicyCommand");892var se_GetCompatibleKafkaVersionsCommand = /* @__PURE__ */ __name(async (input, context) => {893  const b = (0, import_core.requestBuilder)(input, context);894  const headers = {};895  b.bp("/v1/compatible-kafka-versions");896  const query = (0, import_smithy_client.map)({897    [_cA]: [, input[_CA]]898  });899  let body;900  b.m("GET").h(headers).q(query).b(body);901  return b.build();902}, "se_GetCompatibleKafkaVersionsCommand");903var se_ListClientVpcConnectionsCommand = /* @__PURE__ */ __name(async (input, context) => {904  const b = (0, import_core.requestBuilder)(input, context);905  const headers = {};906  b.bp("/v1/clusters/{ClusterArn}/client-vpc-connections");907  b.p("ClusterArn", () => input.ClusterArn, "{ClusterArn}", false);908  const query = (0, import_smithy_client.map)({909    [_mR]: [() => input.MaxResults !== void 0, () => input[_MR].toString()],910    [_nT]: [, input[_NT]]911  });912  let body;913  b.m("GET").h(headers).q(query).b(body);914  return b.build();915}, "se_ListClientVpcConnectionsCommand");916var se_ListClusterOperationsCommand = /* @__PURE__ */ __name(async (input, context) => {917  const b = (0, import_core.requestBuilder)(input, context);918  const headers = {};919  b.bp("/v1/clusters/{ClusterArn}/operations");920  b.p("ClusterArn", () => input.ClusterArn, "{ClusterArn}", false);921  const query = (0, import_smithy_client.map)({922    [_mR]: [() => input.MaxResults !== void 0, () => input[_MR].toString()],923    [_nT]: [, input[_NT]]924  });925  let body;926  b.m("GET").h(headers).q(query).b(body);927  return b.build();928}, "se_ListClusterOperationsCommand");929var se_ListClusterOperationsV2Command = /* @__PURE__ */ __name(async (input, context) => {930  const b = (0, import_core.requestBuilder)(input, context);931  const headers = {};932  b.bp("/api/v2/clusters/{ClusterArn}/operations");933  b.p("ClusterArn", () => input.ClusterArn, "{ClusterArn}", false);934  const query = (0, import_smithy_client.map)({935    [_mR]: [() => input.MaxResults !== void 0, () => input[_MR].toString()],936    [_nT]: [, input[_NT]]937  });938  let body;939  b.m("GET").h(headers).q(query).b(body);940  return b.build();941}, "se_ListClusterOperationsV2Command");942var se_ListClustersCommand = /* @__PURE__ */ __name(async (input, context) => {943  const b = (0, import_core.requestBuilder)(input, context);944  const headers = {};945  b.bp("/v1/clusters");946  const query = (0, import_smithy_client.map)({947    [_cNF]: [, input[_CNF]],948    [_mR]: [() => input.MaxResults !== void 0, () => input[_MR].toString()],949    [_nT]: [, input[_NT]]950  });951  let body;952  b.m("GET").h(headers).q(query).b(body);953  return b.build();954}, "se_ListClustersCommand");955var se_ListClustersV2Command = /* @__PURE__ */ __name(async (input, context) => {956  const b = (0, import_core.requestBuilder)(input, context);957  const headers = {};958  b.bp("/api/v2/clusters");959  const query = (0, import_smithy_client.map)({960    [_cNF]: [, input[_CNF]],961    [_cTF]: [, input[_CTF]],962    [_mR]: [() => input.MaxResults !== void 0, () => input[_MR].toString()],963    [_nT]: [, input[_NT]]964  });965  let body;966  b.m("GET").h(headers).q(query).b(body);967  return b.build();968}, "se_ListClustersV2Command");969var se_ListConfigurationRevisionsCommand = /* @__PURE__ */ __name(async (input, context) => {970  const b = (0, import_core.requestBuilder)(input, context);971  const headers = {};972  b.bp("/v1/configurations/{Arn}/revisions");973  b.p("Arn", () => input.Arn, "{Arn}", false);974  const query = (0, import_smithy_client.map)({975    [_mR]: [() => input.MaxResults !== void 0, () => input[_MR].toString()],976    [_nT]: [, input[_NT]]977  });978  let body;979  b.m("GET").h(headers).q(query).b(body);980  return b.build();981}, "se_ListConfigurationRevisionsCommand");982var se_ListConfigurationsCommand = /* @__PURE__ */ __name(async (input, context) => {983  const b = (0, import_core.requestBuilder)(input, context);984  const headers = {};985  b.bp("/v1/configurations");986  const query = (0, import_smithy_client.map)({987    [_mR]: [() => input.MaxResults !== void 0, () => input[_MR].toString()],988    [_nT]: [, input[_NT]]989  });990  let body;991  b.m("GET").h(headers).q(query).b(body);992  return b.build();993}, "se_ListConfigurationsCommand");994var se_ListKafkaVersionsCommand = /* @__PURE__ */ __name(async (input, context) => {995  const b = (0, import_core.requestBuilder)(input, context);996  const headers = {};997  b.bp("/v1/kafka-versions");998  const query = (0, import_smithy_client.map)({999    [_mR]: [() => input.MaxResults !== void 0, () => input[_MR].toString()],1000    [_nT]: [, input[_NT]]1001  });1002  let body;1003  b.m("GET").h(headers).q(query).b(body);1004  return b.build();1005}, "se_ListKafkaVersionsCommand");1006var se_ListNodesCommand = /* @__PURE__ */ __name(async (input, context) => {1007  const b = (0, import_core.requestBuilder)(input, context);1008  const headers = {};1009  b.bp("/v1/clusters/{ClusterArn}/nodes");1010  b.p("ClusterArn", () => input.ClusterArn, "{ClusterArn}", false);1011  const query = (0, import_smithy_client.map)({1012    [_mR]: [() => input.MaxResults !== void 0, () => input[_MR].toString()],1013    [_nT]: [, input[_NT]]1014  });1015  let body;1016  b.m("GET").h(headers).q(query).b(body);1017  return b.build();1018}, "se_ListNodesCommand");1019var se_ListReplicatorsCommand = /* @__PURE__ */ __name(async (input, context) => {1020  const b = (0, import_core.requestBuilder)(input, context);1021  const headers = {};1022  b.bp("/replication/v1/replicators");1023  const query = (0, import_smithy_client.map)({1024    [_mR]: [() => input.MaxResults !== void 0, () => input[_MR].toString()],1025    [_nT]: [, input[_NT]],1026    [_rNF]: [, input[_RNF]]1027  });1028  let body;1029  b.m("GET").h(headers).q(query).b(body);1030  return b.build();1031}, "se_ListReplicatorsCommand");1032var se_ListScramSecretsCommand = /* @__PURE__ */ __name(async (input, context) => {1033  const b = (0, import_core.requestBuilder)(input, context);1034  const headers = {};1035  b.bp("/v1/clusters/{ClusterArn}/scram-secrets");1036  b.p("ClusterArn", () => input.ClusterArn, "{ClusterArn}", false);1037  const query = (0, import_smithy_client.map)({1038    [_mR]: [() => input.MaxResults !== void 0, () => input[_MR].toString()],1039    [_nT]: [, input[_NT]]1040  });1041  let body;1042  b.m("GET").h(headers).q(query).b(body);1043  return b.build();1044}, "se_ListScramSecretsCommand");1045var se_ListTagsForResourceCommand = /* @__PURE__ */ __name(async (input, context) => {1046  const b = (0, import_core.requestBuilder)(input, context);1047  const headers = {};1048  b.bp("/v1/tags/{ResourceArn}");1049  b.p("ResourceArn", () => input.ResourceArn, "{ResourceArn}", false);1050  let body;1051  b.m("GET").h(headers).b(body);1052  return b.build();1053}, "se_ListTagsForResourceCommand");1054var se_ListVpcConnectionsCommand = /* @__PURE__ */ __name(async (input, context) => {1055  const b = (0, import_core.requestBuilder)(input, context);1056  const headers = {};1057  b.bp("/v1/vpc-connections");1058  const query = (0, import_smithy_client.map)({1059    [_mR]: [() => input.MaxResults !== void 0, () => input[_MR].toString()],1060    [_nT]: [, input[_NT]]1061  });1062  let body;1063  b.m("GET").h(headers).q(query).b(body);1064  return b.build();1065}, "se_ListVpcConnectionsCommand");1066var se_PutClusterPolicyCommand = /* @__PURE__ */ __name(async (input, context) => {1067  const b = (0, import_core.requestBuilder)(input, context);1068  const headers = {1069    "content-type": "application/json"1070  };1071  b.bp("/v1/clusters/{ClusterArn}/policy");1072  b.p("ClusterArn", () => input.ClusterArn, "{ClusterArn}", false);1073  let body;1074  body = JSON.stringify(1075    (0, import_smithy_client.take)(input, {1076      currentVersion: [, , `CurrentVersion`],1077      policy: [, , `Policy`]1078    })1079  );1080  b.m("PUT").h(headers).b(body);1081  return b.build();1082}, "se_PutClusterPolicyCommand");1083var se_RebootBrokerCommand = /* @__PURE__ */ __name(async (input, context) => {1084  const b = (0, import_core.requestBuilder)(input, context);1085  const headers = {1086    "content-type": "application/json"1087  };1088  b.bp("/v1/clusters/{ClusterArn}/reboot-broker");1089  b.p("ClusterArn", () => input.ClusterArn, "{ClusterArn}", false);1090  let body;1091  body = JSON.stringify(1092    (0, import_smithy_client.take)(input, {1093      brokerIds: [, (_) => (0, import_smithy_client._json)(_), `BrokerIds`]1094    })1095  );1096  b.m("PUT").h(headers).b(body);1097  return b.build();1098}, "se_RebootBrokerCommand");1099var se_RejectClientVpcConnectionCommand = /* @__PURE__ */ __name(async (input, context) => {1100  const b = (0, import_core.requestBuilder)(input, context);1101  const headers = {1102    "content-type": "application/json"1103  };1104  b.bp("/v1/clusters/{ClusterArn}/client-vpc-connection");1105  b.p("ClusterArn", () => input.ClusterArn, "{ClusterArn}", false);1106  let body;1107  body = JSON.stringify(1108    (0, import_smithy_client.take)(input, {1109      vpcConnectionArn: [, , `VpcConnectionArn`]1110    })1111  );1112  b.m("PUT").h(headers).b(body);1113  return b.build();1114}, "se_RejectClientVpcConnectionCommand");1115var se_TagResourceCommand = /* @__PURE__ */ __name(async (input, context) => {1116  const b = (0, import_core.requestBuilder)(input, context);1117  const headers = {1118    "content-type": "application/json"1119  };1120  b.bp("/v1/tags/{ResourceArn}");1121  b.p("ResourceArn", () => input.ResourceArn, "{ResourceArn}", false);1122  let body;1123  body = JSON.stringify(1124    (0, import_smithy_client.take)(input, {1125      tags: [, (_) => (0, import_smithy_client._json)(_), `Tags`]1126    })1127  );1128  b.m("POST").h(headers).b(body);1129  return b.build();1130}, "se_TagResourceCommand");1131var se_UntagResourceCommand = /* @__PURE__ */ __name(async (input, context) => {1132  const b = (0, import_core.requestBuilder)(input, context);1133  const headers = {};1134  b.bp("/v1/tags/{ResourceArn}");1135  b.p("ResourceArn", () => input.ResourceArn, "{ResourceArn}", false);1136  const query = (0, import_smithy_client.map)({1137    [_tK]: [(0, import_smithy_client.expectNonNull)(input.TagKeys, `TagKeys`) != null, () => input[_TK] || []]1138  });1139  let body;1140  b.m("DELETE").h(headers).q(query).b(body);1141  return b.build();1142}, "se_UntagResourceCommand");1143var se_UpdateBrokerCountCommand = /* @__PURE__ */ __name(async (input, context) => {1144  const b = (0, import_core.requestBuilder)(input, context);1145  const headers = {1146    "content-type": "application/json"1147  };1148  b.bp("/v1/clusters/{ClusterArn}/nodes/count");1149  b.p("ClusterArn", () => input.ClusterArn, "{ClusterArn}", false);1150  let body;1151  body = JSON.stringify(1152    (0, import_smithy_client.take)(input, {1153      currentVersion: [, , `CurrentVersion`],1154      targetNumberOfBrokerNodes: [, , `TargetNumberOfBrokerNodes`]1155    })1156  );1157  b.m("PUT").h(headers).b(body);1158  return b.build();1159}, "se_UpdateBrokerCountCommand");1160var se_UpdateBrokerStorageCommand = /* @__PURE__ */ __name(async (input, context) => {1161  const b = (0, import_core.requestBuilder)(input, context);1162  const headers = {1163    "content-type": "application/json"1164  };1165  b.bp("/v1/clusters/{ClusterArn}/nodes/storage");1166  b.p("ClusterArn", () => input.ClusterArn, "{ClusterArn}", false);1167  let body;1168  body = JSON.stringify(1169    (0, import_smithy_client.take)(input, {1170      currentVersion: [, , `CurrentVersion`],1171      targetBrokerEBSVolumeInfo: [, (_) => se___listOfBrokerEBSVolumeInfo(_, context), `TargetBrokerEBSVolumeInfo`]1172    })1173  );1174  b.m("PUT").h(headers).b(body);1175  return b.build();1176}, "se_UpdateBrokerStorageCommand");1177var se_UpdateBrokerTypeCommand = /* @__PURE__ */ __name(async (input, context) => {1178  const b = (0, import_core.requestBuilder)(input, context);1179  const headers = {1180    "content-type": "application/json"1181  };1182  b.bp("/v1/clusters/{ClusterArn}/nodes/type");1183  b.p("ClusterArn", () => input.ClusterArn, "{ClusterArn}", false);1184  let body;1185  body = JSON.stringify(1186    (0, import_smithy_client.take)(input, {1187      currentVersion: [, , `CurrentVersion`],1188      targetInstanceType: [, , `TargetInstanceType`]1189    })1190  );1191  b.m("PUT").h(headers).b(body);1192  return b.build();1193}, "se_UpdateBrokerTypeCommand");1194var se_UpdateClusterConfigurationCommand = /* @__PURE__ */ __name(async (input, context) => {1195  const b = (0, import_core.requestBuilder)(input, context);1196  const headers = {1197    "content-type": "application/json"1198  };1199  b.bp("/v1/clusters/{ClusterArn}/configuration");1200  b.p("ClusterArn", () => input.ClusterArn, "{ClusterArn}", false);1201  let body;1202  body = JSON.stringify(1203    (0, import_smithy_client.take)(input, {1204      configurationInfo: [, (_) => se_ConfigurationInfo(_, context), `ConfigurationInfo`],1205      currentVersion: [, , `CurrentVersion`]1206    })1207  );1208  b.m("PUT").h(headers).b(body);1209  return b.build();1210}, "se_UpdateClusterConfigurationCommand");1211var se_UpdateClusterKafkaVersionCommand = /* @__PURE__ */ __name(async (input, context) => {1212  const b = (0, import_core.requestBuilder)(input, context);1213  const headers = {1214    "content-type": "application/json"1215  };1216  b.bp("/v1/clusters/{ClusterArn}/version");1217  b.p("ClusterArn", () => input.ClusterArn, "{ClusterArn}", false);1218  let body;1219  body = JSON.stringify(1220    (0, import_smithy_client.take)(input, {1221      configurationInfo: [, (_) => se_ConfigurationInfo(_, context), `ConfigurationInfo`],1222      currentVersion: [, , `CurrentVersion`],1223      targetKafkaVersion: [, , `TargetKafkaVersion`]1224    })1225  );1226  b.m("PUT").h(headers).b(body);1227  return b.build();1228}, "se_UpdateClusterKafkaVersionCommand");1229var se_UpdateConfigurationCommand = /* @__PURE__ */ __name(async (input, context) => {1230  const b = (0, import_core.requestBuilder)(input, context);1231  const headers = {1232    "content-type": "application/json"1233  };1234  b.bp("/v1/configurations/{Arn}");1235  b.p("Arn", () => input.Arn, "{Arn}", false);1236  let body;1237  body = JSON.stringify(1238    (0, import_smithy_client.take)(input, {1239      description: [, , `Description`],1240      serverProperties: [, (_) => context.base64Encoder(_), `ServerProperties`]1241    })1242  );1243  b.m("PUT").h(headers).b(body);1244  return b.build();1245}, "se_UpdateConfigurationCommand");1246var se_UpdateConnectivityCommand = /* @__PURE__ */ __name(async (input, context) => {1247  const b = (0, import_core.requestBuilder)(input, context);1248  const headers = {1249    "content-type": "application/json"1250  };1251  b.bp("/v1/clusters/{ClusterArn}/connectivity");1252  b.p("ClusterArn", () => input.ClusterArn, "{ClusterArn}", false);1253  let body;1254  body = JSON.stringify(1255    (0, import_smithy_client.take)(input, {1256      connectivityInfo: [, (_) => se_ConnectivityInfo(_, context), `ConnectivityInfo`],1257      currentVersion: [, , `CurrentVersion`]1258    })1259  );1260  b.m("PUT").h(headers).b(body);1261  return b.build();1262}, "se_UpdateConnectivityCommand");1263var se_UpdateMonitoringCommand = /* @__PURE__ */ __name(async (input, context) => {1264  const b = (0, import_core.requestBuilder)(input, context);1265  const headers = {1266    "content-type": "application/json"1267  };1268  b.bp("/v1/clusters/{ClusterArn}/monitoring");1269  b.p("ClusterArn", () => input.ClusterArn, "{ClusterArn}", false);1270  let body;1271  body = JSON.stringify(1272    (0, import_smithy_client.take)(input, {1273      currentVersion: [, , `CurrentVersion`],1274      enhancedMonitoring: [, , `EnhancedMonitoring`],1275      loggingInfo: [, (_) => se_LoggingInfo(_, context), `LoggingInfo`],1276      openMonitoring: [, (_) => se_OpenMonitoringInfo(_, context), `OpenMonitoring`]1277    })1278  );1279  b.m("PUT").h(headers).b(body);1280  return b.build();1281}, "se_UpdateMonitoringCommand");1282var se_UpdateReplicationInfoCommand = /* @__PURE__ */ __name(async (input, context) => {1283  const b = (0, import_core.requestBuilder)(input, context);1284  const headers = {1285    "content-type": "application/json"1286  };1287  b.bp("/replication/v1/replicators/{ReplicatorArn}/replication-info");1288  b.p("ReplicatorArn", () => input.ReplicatorArn, "{ReplicatorArn}", false);1289  let body;1290  body = JSON.stringify(1291    (0, import_smithy_client.take)(input, {1292      consumerGroupReplication: [, (_) => se_ConsumerGroupReplicationUpdate(_, context), `ConsumerGroupReplication`],1293      currentVersion: [, , `CurrentVersion`],1294      sourceKafkaClusterArn: [, , `SourceKafkaClusterArn`],1295      targetKafkaClusterArn: [, , `TargetKafkaClusterArn`],1296      topicReplication: [, (_) => se_TopicReplicationUpdate(_, context), `TopicReplication`]1297    })1298  );1299  b.m("PUT").h(headers).b(body);1300  return b.build();1301}, "se_UpdateReplicationInfoCommand");1302var se_UpdateSecurityCommand = /* @__PURE__ */ __name(async (input, context) => {1303  const b = (0, import_core.requestBuilder)(input, context);1304  const headers = {1305    "content-type": "application/json"1306  };1307  b.bp("/v1/clusters/{ClusterArn}/security");1308  b.p("ClusterArn", () => input.ClusterArn, "{ClusterArn}", false);1309  let body;1310  body = JSON.stringify(1311    (0, import_smithy_client.take)(input, {1312      clientAuthentication: [, (_) => se_ClientAuthentication(_, context), `ClientAuthentication`],1313      currentVersion: [, , `CurrentVersion`],1314      encryptionInfo: [, (_) => se_EncryptionInfo(_, context), `EncryptionInfo`]1315    })1316  );1317  b.m("PATCH").h(headers).b(body);1318  return b.build();1319}, "se_UpdateSecurityCommand");1320var se_UpdateStorageCommand = /* @__PURE__ */ __name(async (input, context) => {1321  const b = (0, import_core.requestBuilder)(input, context);1322  const headers = {1323    "content-type": "application/json"1324  };1325  b.bp("/v1/clusters/{ClusterArn}/storage");1326  b.p("ClusterArn", () => input.ClusterArn, "{ClusterArn}", false);1327  let body;1328  body = JSON.stringify(1329    (0, import_smithy_client.take)(input, {1330      currentVersion: [, , `CurrentVersion`],1331      provisionedThroughput: [, (_) => se_ProvisionedThroughput(_, context), `ProvisionedThroughput`],1332      storageMode: [, , `StorageMode`],1333      volumeSizeGB: [, , `VolumeSizeGB`]1334    })1335  );1336  b.m("PUT").h(headers).b(body);1337  return b.build();1338}, "se_UpdateStorageCommand");1339var de_BatchAssociateScramSecretCommand = /* @__PURE__ */ __name(async (output, context) => {1340  if (output.statusCode !== 200 && output.statusCode >= 300) {1341    return de_CommandError(output, context);1342  }1343  const contents = (0, import_smithy_client.map)({1344    $metadata: deserializeMetadata(output)1345  });1346  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");1347  const doc = (0, import_smithy_client.take)(data, {1348    ClusterArn: [, import_smithy_client.expectString, `clusterArn`],1349    UnprocessedScramSecrets: [, (_) => de___listOfUnprocessedScramSecret(_, context), `unprocessedScramSecrets`]1350  });1351  Object.assign(contents, doc);1352  return contents;1353}, "de_BatchAssociateScramSecretCommand");1354var de_BatchDisassociateScramSecretCommand = /* @__PURE__ */ __name(async (output, context) => {1355  if (output.statusCode !== 200 && output.statusCode >= 300) {1356    return de_CommandError(output, context);1357  }1358  const contents = (0, import_smithy_client.map)({1359    $metadata: deserializeMetadata(output)1360  });1361  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");1362  const doc = (0, import_smithy_client.take)(data, {1363    ClusterArn: [, import_smithy_client.expectString, `clusterArn`],1364    UnprocessedScramSecrets: [, (_) => de___listOfUnprocessedScramSecret(_, context), `unprocessedScramSecrets`]1365  });1366  Object.assign(contents, doc);1367  return contents;1368}, "de_BatchDisassociateScramSecretCommand");1369var de_CreateClusterCommand = /* @__PURE__ */ __name(async (output, context) => {1370  if (output.statusCode !== 200 && output.statusCode >= 300) {1371    return de_CommandError(output, context);1372  }1373  const contents = (0, import_smithy_client.map)({1374    $metadata: deserializeMetadata(output)1375  });1376  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");1377  const doc = (0, import_smithy_client.take)(data, {1378    ClusterArn: [, import_smithy_client.expectString, `clusterArn`],1379    ClusterName: [, import_smithy_client.expectString, `clusterName`],1380    State: [, import_smithy_client.expectString, `state`]1381  });1382  Object.assign(contents, doc);1383  return contents;1384}, "de_CreateClusterCommand");1385var de_CreateClusterV2Command = /* @__PURE__ */ __name(async (output, context) => {1386  if (output.statusCode !== 200 && output.statusCode >= 300) {1387    return de_CommandError(output, context);1388  }1389  const contents = (0, import_smithy_client.map)({1390    $metadata: deserializeMetadata(output)1391  });1392  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");1393  const doc = (0, import_smithy_client.take)(data, {1394    ClusterArn: [, import_smithy_client.expectString, `clusterArn`],1395    ClusterName: [, import_smithy_client.expectString, `clusterName`],1396    ClusterType: [, import_smithy_client.expectString, `clusterType`],1397    State: [, import_smithy_client.expectString, `state`]1398  });1399  Object.assign(contents, doc);1400  return contents;1401}, "de_CreateClusterV2Command");1402var de_CreateConfigurationCommand = /* @__PURE__ */ __name(async (output, context) => {1403  if (output.statusCode !== 200 && output.statusCode >= 300) {1404    return de_CommandError(output, context);1405  }1406  const contents = (0, import_smithy_client.map)({1407    $metadata: deserializeMetadata(output)1408  });1409  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");1410  const doc = (0, import_smithy_client.take)(data, {1411    Arn: [, import_smithy_client.expectString, `arn`],1412    CreationTime: [, (_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseRfc3339DateTimeWithOffset)(_)), `creationTime`],1413    LatestRevision: [, (_) => de_ConfigurationRevision(_, context), `latestRevision`],1414    Name: [, import_smithy_client.expectString, `name`],1415    State: [, import_smithy_client.expectString, `state`]1416  });1417  Object.assign(contents, doc);1418  return contents;1419}, "de_CreateConfigurationCommand");1420var de_CreateReplicatorCommand = /* @__PURE__ */ __name(async (output, context) => {1421  if (output.statusCode !== 200 && output.statusCode >= 300) {1422    return de_CommandError(output, context);1423  }1424  const contents = (0, import_smithy_client.map)({1425    $metadata: deserializeMetadata(output)1426  });1427  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");1428  const doc = (0, import_smithy_client.take)(data, {1429    ReplicatorArn: [, import_smithy_client.expectString, `replicatorArn`],1430    ReplicatorName: [, import_smithy_client.expectString, `replicatorName`],1431    ReplicatorState: [, import_smithy_client.expectString, `replicatorState`]1432  });1433  Object.assign(contents, doc);1434  return contents;1435}, "de_CreateReplicatorCommand");1436var de_CreateVpcConnectionCommand = /* @__PURE__ */ __name(async (output, context) => {1437  if (output.statusCode !== 200 && output.statusCode >= 300) {1438    return de_CommandError(output, context);1439  }1440  const contents = (0, import_smithy_client.map)({1441    $metadata: deserializeMetadata(output)1442  });1443  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");1444  const doc = (0, import_smithy_client.take)(data, {1445    Authentication: [, import_smithy_client.expectString, `authentication`],1446    ClientSubnets: [, import_smithy_client._json, `clientSubnets`],1447    CreationTime: [, (_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseRfc3339DateTimeWithOffset)(_)), `creationTime`],1448    SecurityGroups: [, import_smithy_client._json, `securityGroups`],1449    State: [, import_smithy_client.expectString, `state`],1450    Tags: [, import_smithy_client._json, `tags`],1451    VpcConnectionArn: [, import_smithy_client.expectString, `vpcConnectionArn`],1452    VpcId: [, import_smithy_client.expectString, `vpcId`]1453  });1454  Object.assign(contents, doc);1455  return contents;1456}, "de_CreateVpcConnectionCommand");1457var de_DeleteClusterCommand = /* @__PURE__ */ __name(async (output, context) => {1458  if (output.statusCode !== 200 && output.statusCode >= 300) {1459    return de_CommandError(output, context);1460  }1461  const contents = (0, import_smithy_client.map)({1462    $metadata: deserializeMetadata(output)1463  });1464  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");1465  const doc = (0, import_smithy_client.take)(data, {1466    ClusterArn: [, import_smithy_client.expectString, `clusterArn`],1467    State: [, import_smithy_client.expectString, `state`]1468  });1469  Object.assign(contents, doc);1470  return contents;1471}, "de_DeleteClusterCommand");1472var de_DeleteClusterPolicyCommand = /* @__PURE__ */ __name(async (output, context) => {1473  if (output.statusCode !== 200 && output.statusCode >= 300) {1474    return de_CommandError(output, context);1475  }1476  const contents = (0, import_smithy_client.map)({1477    $metadata: deserializeMetadata(output)1478  });1479  await (0, import_smithy_client.collectBody)(output.body, context);1480  return contents;1481}, "de_DeleteClusterPolicyCommand");1482var de_DeleteConfigurationCommand = /* @__PURE__ */ __name(async (output, context) => {1483  if (output.statusCode !== 200 && output.statusCode >= 300) {1484    return de_CommandError(output, context);1485  }1486  const contents = (0, import_smithy_client.map)({1487    $metadata: deserializeMetadata(output)1488  });1489  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");1490  const doc = (0, import_smithy_client.take)(data, {1491    Arn: [, import_smithy_client.expectString, `arn`],1492    State: [, import_smithy_client.expectString, `state`]1493  });1494  Object.assign(contents, doc);1495  return contents;1496}, "de_DeleteConfigurationCommand");1497var de_DeleteReplicatorCommand = /* @__PURE__ */ __name(async (output, context) => {1498  if (output.statusCode !== 200 && output.statusCode >= 300) {1499    return de_CommandError(output, context);1500  }1501  const contents = (0, import_smithy_client.map)({1502    $metadata: deserializeMetadata(output)1503  });1504  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");1505  const doc = (0, import_smithy_client.take)(data, {1506    ReplicatorArn: [, import_smithy_client.expectString, `replicatorArn`],1507    ReplicatorState: [, import_smithy_client.expectString, `replicatorState`]1508  });1509  Object.assign(contents, doc);1510  return contents;1511}, "de_DeleteReplicatorCommand");1512var de_DeleteVpcConnectionCommand = /* @__PURE__ */ __name(async (output, context) => {1513  if (output.statusCode !== 200 && output.statusCode >= 300) {1514    return de_CommandError(output, context);1515  }1516  const contents = (0, import_smithy_client.map)({1517    $metadata: deserializeMetadata(output)1518  });1519  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");1520  const doc = (0, import_smithy_client.take)(data, {1521    State: [, import_smithy_client.expectString, `state`],1522    VpcConnectionArn: [, import_smithy_client.expectString, `vpcConnectionArn`]1523  });1524  Object.assign(contents, doc);1525  return contents;1526}, "de_DeleteVpcConnectionCommand");1527var de_DescribeClusterCommand = /* @__PURE__ */ __name(async (output, context) => {1528  if (output.statusCode !== 200 && output.statusCode >= 300) {1529    return de_CommandError(output, context);1530  }1531  const contents = (0, import_smithy_client.map)({1532    $metadata: deserializeMetadata(output)1533  });1534  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");1535  const doc = (0, import_smithy_client.take)(data, {1536    ClusterInfo: [, (_) => de_ClusterInfo(_, context), `clusterInfo`]1537  });1538  Object.assign(contents, doc);1539  return contents;1540}, "de_DescribeClusterCommand");1541var de_DescribeClusterOperationCommand = /* @__PURE__ */ __name(async (output, context) => {1542  if (output.statusCode !== 200 && output.statusCode >= 300) {1543    return de_CommandError(output, context);1544  }1545  const contents = (0, import_smithy_client.map)({1546    $metadata: deserializeMetadata(output)1547  });1548  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");1549  const doc = (0, import_smithy_client.take)(data, {1550    ClusterOperationInfo: [, (_) => de_ClusterOperationInfo(_, context), `clusterOperationInfo`]1551  });1552  Object.assign(contents, doc);1553  return contents;1554}, "de_DescribeClusterOperationCommand");1555var de_DescribeClusterOperationV2Command = /* @__PURE__ */ __name(async (output, context) => {1556  if (output.statusCode !== 200 && output.statusCode >= 300) {1557    return de_CommandError(output, context);1558  }1559  const contents = (0, import_smithy_client.map)({1560    $metadata: deserializeMetadata(output)1561  });1562  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");1563  const doc = (0, import_smithy_client.take)(data, {1564    ClusterOperationInfo: [, (_) => de_ClusterOperationV2(_, context), `clusterOperationInfo`]1565  });1566  Object.assign(contents, doc);1567  return contents;1568}, "de_DescribeClusterOperationV2Command");1569var de_DescribeClusterV2Command = /* @__PURE__ */ __name(async (output, context) => {1570  if (output.statusCode !== 200 && output.statusCode >= 300) {1571    return de_CommandError(output, context);1572  }1573  const contents = (0, import_smithy_client.map)({1574    $metadata: deserializeMetadata(output)1575  });1576  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");1577  const doc = (0, import_smithy_client.take)(data, {1578    ClusterInfo: [, (_) => de_Cluster(_, context), `clusterInfo`]1579  });1580  Object.assign(contents, doc);1581  return contents;1582}, "de_DescribeClusterV2Command");1583var de_DescribeConfigurationCommand = /* @__PURE__ */ __name(async (output, context) => {1584  if (output.statusCode !== 200 && output.statusCode >= 300) {1585    return de_CommandError(output, context);1586  }1587  const contents = (0, import_smithy_client.map)({1588    $metadata: deserializeMetadata(output)1589  });1590  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");1591  const doc = (0, import_smithy_client.take)(data, {1592    Arn: [, import_smithy_client.expectString, `arn`],1593    CreationTime: [, (_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseRfc3339DateTimeWithOffset)(_)), `creationTime`],1594    Description: [, import_smithy_client.expectString, `description`],1595    KafkaVersions: [, import_smithy_client._json, `kafkaVersions`],1596    LatestRevision: [, (_) => de_ConfigurationRevision(_, context), `latestRevision`],1597    Name: [, import_smithy_client.expectString, `name`],1598    State: [, import_smithy_client.expectString, `state`]1599  });1600  Object.assign(contents, doc);1601  return contents;1602}, "de_DescribeConfigurationCommand");1603var de_DescribeConfigurationRevisionCommand = /* @__PURE__ */ __name(async (output, context) => {1604  if (output.statusCode !== 200 && output.statusCode >= 300) {1605    return de_CommandError(output, context);1606  }1607  const contents = (0, import_smithy_client.map)({1608    $metadata: deserializeMetadata(output)1609  });1610  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");1611  const doc = (0, import_smithy_client.take)(data, {1612    Arn: [, import_smithy_client.expectString, `arn`],1613    CreationTime: [, (_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseRfc3339DateTimeWithOffset)(_)), `creationTime`],1614    Description: [, import_smithy_client.expectString, `description`],1615    Revision: [, import_smithy_client.expectLong, `revision`],1616    ServerProperties: [, context.base64Decoder, `serverProperties`]1617  });1618  Object.assign(contents, doc);1619  return contents;1620}, "de_DescribeConfigurationRevisionCommand");1621var de_DescribeReplicatorCommand = /* @__PURE__ */ __name(async (output, context) => {1622  if (output.statusCode !== 200 && output.statusCode >= 300) {1623    return de_CommandError(output, context);1624  }1625  const contents = (0, import_smithy_client.map)({1626    $metadata: deserializeMetadata(output)1627  });1628  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");1629  const doc = (0, import_smithy_client.take)(data, {1630    CreationTime: [, (_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseRfc3339DateTimeWithOffset)(_)), `creationTime`],1631    CurrentVersion: [, import_smithy_client.expectString, `currentVersion`],1632    IsReplicatorReference: [, import_smithy_client.expectBoolean, `isReplicatorReference`],1633    KafkaClusters: [, (_) => de___listOfKafkaClusterDescription(_, context), `kafkaClusters`],1634    ReplicationInfoList: [, (_) => de___listOfReplicationInfoDescription(_, context), `replicationInfoList`],1635    ReplicatorArn: [, import_smithy_client.expectString, `replicatorArn`],1636    ReplicatorDescription: [, import_smithy_client.expectString, `replicatorDescription`],1637    ReplicatorName: [, import_smithy_client.expectString, `replicatorName`],1638    ReplicatorResourceArn: [, import_smithy_client.expectString, `replicatorResourceArn`],1639    ReplicatorState: [, import_smithy_client.expectString, `replicatorState`],1640    ServiceExecutionRoleArn: [, import_smithy_client.expectString, `serviceExecutionRoleArn`],1641    StateInfo: [, (_) => de_ReplicationStateInfo(_, context), `stateInfo`],1642    Tags: [, import_smithy_client._json, `tags`]1643  });1644  Object.assign(contents, doc);1645  return contents;1646}, "de_DescribeReplicatorCommand");1647var de_DescribeVpcConnectionCommand = /* @__PURE__ */ __name(async (output, context) => {1648  if (output.statusCode !== 200 && output.statusCode >= 300) {1649    return de_CommandError(output, context);1650  }1651  const contents = (0, import_smithy_client.map)({1652    $metadata: deserializeMetadata(output)1653  });1654  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");1655  const doc = (0, import_smithy_client.take)(data, {1656    Authentication: [, import_smithy_client.expectString, `authentication`],1657    CreationTime: [, (_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseRfc3339DateTimeWithOffset)(_)), `creationTime`],1658    SecurityGroups: [, import_smithy_client._json, `securityGroups`],1659    State: [, import_smithy_client.expectString, `state`],1660    Subnets: [, import_smithy_client._json, `subnets`],1661    Tags: [, import_smithy_client._json, `tags`],1662    TargetClusterArn: [, import_smithy_client.expectString, `targetClusterArn`],1663    VpcConnectionArn: [, import_smithy_client.expectString, `vpcConnectionArn`],1664    VpcId: [, import_smithy_client.expectString, `vpcId`]1665  });1666  Object.assign(contents, doc);1667  return contents;1668}, "de_DescribeVpcConnectionCommand");1669var de_GetBootstrapBrokersCommand = /* @__PURE__ */ __name(async (output, context) => {1670  if (output.statusCode !== 200 && output.statusCode >= 300) {1671    return de_CommandError(output, context);1672  }1673  const contents = (0, import_smithy_client.map)({1674    $metadata: deserializeMetadata(output)1675  });1676  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");1677  const doc = (0, import_smithy_client.take)(data, {1678    BootstrapBrokerString: [, import_smithy_client.expectString, `bootstrapBrokerString`],1679    BootstrapBrokerStringPublicSaslIam: [, import_smithy_client.expectString, `bootstrapBrokerStringPublicSaslIam`],1680    BootstrapBrokerStringPublicSaslScram: [, import_smithy_client.expectString, `bootstrapBrokerStringPublicSaslScram`],1681    BootstrapBrokerStringPublicTls: [, import_smithy_client.expectString, `bootstrapBrokerStringPublicTls`],1682    BootstrapBrokerStringSaslIam: [, import_smithy_client.expectString, `bootstrapBrokerStringSaslIam`],1683    BootstrapBrokerStringSaslScram: [, import_smithy_client.expectString, `bootstrapBrokerStringSaslScram`],1684    BootstrapBrokerStringTls: [, import_smithy_client.expectString, `bootstrapBrokerStringTls`],1685    BootstrapBrokerStringVpcConnectivitySaslIam: [, import_smithy_client.expectString, `bootstrapBrokerStringVpcConnectivitySaslIam`],1686    BootstrapBrokerStringVpcConnectivitySaslScram: [, import_smithy_client.expectString, `bootstrapBrokerStringVpcConnectivitySaslScram`],1687    BootstrapBrokerStringVpcConnectivityTls: [, import_smithy_client.expectString, `bootstrapBrokerStringVpcConnectivityTls`]1688  });1689  Object.assign(contents, doc);1690  return contents;1691}, "de_GetBootstrapBrokersCommand");1692var de_GetClusterPolicyCommand = /* @__PURE__ */ __name(async (output, context) => {1693  if (output.statusCode !== 200 && output.statusCode >= 300) {1694    return de_CommandError(output, context);1695  }1696  const contents = (0, import_smithy_client.map)({1697    $metadata: deserializeMetadata(output)1698  });1699  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");1700  const doc = (0, import_smithy_client.take)(data, {1701    CurrentVersion: [, import_smithy_client.expectString, `currentVersion`],1702    Policy: [, import_smithy_client.expectString, `policy`]1703  });1704  Object.assign(contents, doc);1705  return contents;1706}, "de_GetClusterPolicyCommand");1707var de_GetCompatibleKafkaVersionsCommand = /* @__PURE__ */ __name(async (output, context) => {1708  if (output.statusCode !== 200 && output.statusCode >= 300) {1709    return de_CommandError(output, context);1710  }1711  const contents = (0, import_smithy_client.map)({1712    $metadata: deserializeMetadata(output)1713  });1714  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");1715  const doc = (0, import_smithy_client.take)(data, {1716    CompatibleKafkaVersions: [, (_) => de___listOfCompatibleKafkaVersion(_, context), `compatibleKafkaVersions`]1717  });1718  Object.assign(contents, doc);1719  return contents;1720}, "de_GetCompatibleKafkaVersionsCommand");1721var de_ListClientVpcConnectionsCommand = /* @__PURE__ */ __name(async (output, context) => {1722  if (output.statusCode !== 200 && output.statusCode >= 300) {1723    return de_CommandError(output, context);1724  }1725  const contents = (0, import_smithy_client.map)({1726    $metadata: deserializeMetadata(output)1727  });1728  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");1729  const doc = (0, import_smithy_client.take)(data, {1730    ClientVpcConnections: [, (_) => de___listOfClientVpcConnection(_, context), `clientVpcConnections`],1731    NextToken: [, import_smithy_client.expectString, `nextToken`]1732  });1733  Object.assign(contents, doc);1734  return contents;1735}, "de_ListClientVpcConnectionsCommand");1736var de_ListClusterOperationsCommand = /* @__PURE__ */ __name(async (output, context) => {1737  if (output.statusCode !== 200 && output.statusCode >= 300) {1738    return de_CommandError(output, context);1739  }1740  const contents = (0, import_smithy_client.map)({1741    $metadata: deserializeMetadata(output)1742  });1743  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");1744  const doc = (0, import_smithy_client.take)(data, {1745    ClusterOperationInfoList: [, (_) => de___listOfClusterOperationInfo(_, context), `clusterOperationInfoList`],1746    NextToken: [, import_smithy_client.expectString, `nextToken`]1747  });1748  Object.assign(contents, doc);1749  return contents;1750}, "de_ListClusterOperationsCommand");1751var de_ListClusterOperationsV2Command = /* @__PURE__ */ __name(async (output, context) => {1752  if (output.statusCode !== 200 && output.statusCode >= 300) {1753    return de_CommandError(output, context);1754  }1755  const contents = (0, import_smithy_client.map)({1756    $metadata: deserializeMetadata(output)1757  });1758  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");1759  const doc = (0, import_smithy_client.take)(data, {1760    ClusterOperationInfoList: [, (_) => de___listOfClusterOperationV2Summary(_, context), `clusterOperationInfoList`],1761    NextToken: [, import_smithy_client.expectString, `nextToken`]1762  });1763  Object.assign(contents, doc);1764  return contents;1765}, "de_ListClusterOperationsV2Command");1766var de_ListClustersCommand = /* @__PURE__ */ __name(async (output, context) => {1767  if (output.statusCode !== 200 && output.statusCode >= 300) {1768    return de_CommandError(output, context);1769  }1770  const contents = (0, import_smithy_client.map)({1771    $metadata: deserializeMetadata(output)1772  });1773  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");1774  const doc = (0, import_smithy_client.take)(data, {1775    ClusterInfoList: [, (_) => de___listOfClusterInfo(_, context), `clusterInfoList`],1776    NextToken: [, import_smithy_client.expectString, `nextToken`]1777  });1778  Object.assign(contents, doc);1779  return contents;1780}, "de_ListClustersCommand");1781var de_ListClustersV2Command = /* @__PURE__ */ __name(async (output, context) => {1782  if (output.statusCode !== 200 && output.statusCode >= 300) {1783    return de_CommandError(output, context);1784  }1785  const contents = (0, import_smithy_client.map)({1786    $metadata: deserializeMetadata(output)1787  });1788  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");1789  const doc = (0, import_smithy_client.take)(data, {1790    ClusterInfoList: [, (_) => de___listOfCluster(_, context), `clusterInfoList`],1791    NextToken: [, import_smithy_client.expectString, `nextToken`]1792  });1793  Object.assign(contents, doc);1794  return contents;1795}, "de_ListClustersV2Command");1796var de_ListConfigurationRevisionsCommand = /* @__PURE__ */ __name(async (output, context) => {1797  if (output.statusCode !== 200 && output.statusCode >= 300) {1798    return de_CommandError(output, context);1799  }1800  const contents = (0, import_smithy_client.map)({1801    $metadata: deserializeMetadata(output)1802  });1803  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");1804  const doc = (0, import_smithy_client.take)(data, {1805    NextToken: [, import_smithy_client.expectString, `nextToken`],1806    Revisions: [, (_) => de___listOfConfigurationRevision(_, context), `revisions`]1807  });1808  Object.assign(contents, doc);1809  return contents;1810}, "de_ListConfigurationRevisionsCommand");1811var de_ListConfigurationsCommand = /* @__PURE__ */ __name(async (output, context) => {1812  if (output.statusCode !== 200 && output.statusCode >= 300) {1813    return de_CommandError(output, context);1814  }1815  const contents = (0, import_smithy_client.map)({1816    $metadata: deserializeMetadata(output)1817  });1818  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");1819  const doc = (0, import_smithy_client.take)(data, {1820    Configurations: [, (_) => de___listOfConfiguration(_, context), `configurations`],1821    NextToken: [, import_smithy_client.expectString, `nextToken`]1822  });1823  Object.assign(contents, doc);1824  return contents;1825}, "de_ListConfigurationsCommand");1826var de_ListKafkaVersionsCommand = /* @__PURE__ */ __name(async (output, context) => {1827  if (output.statusCode !== 200 && output.statusCode >= 300) {1828    return de_CommandError(output, context);1829  }1830  const contents = (0, import_smithy_client.map)({1831    $metadata: deserializeMetadata(output)1832  });1833  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");1834  const doc = (0, import_smithy_client.take)(data, {1835    KafkaVersions: [, (_) => de___listOfKafkaVersion(_, context), `kafkaVersions`],1836    NextToken: [, import_smithy_client.expectString, `nextToken`]1837  });1838  Object.assign(contents, doc);1839  return contents;1840}, "de_ListKafkaVersionsCommand");1841var de_ListNodesCommand = /* @__PURE__ */ __name(async (output, context) => {1842  if (output.statusCode !== 200 && output.statusCode >= 300) {1843    return de_CommandError(output, context);1844  }1845  const contents = (0, import_smithy_client.map)({1846    $metadata: deserializeMetadata(output)1847  });1848  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");1849  const doc = (0, import_smithy_client.take)(data, {1850    NextToken: [, import_smithy_client.expectString, `nextToken`],1851    NodeInfoList: [, (_) => de___listOfNodeInfo(_, context), `nodeInfoList`]1852  });1853  Object.assign(contents, doc);1854  return contents;1855}, "de_ListNodesCommand");1856var de_ListReplicatorsCommand = /* @__PURE__ */ __name(async (output, context) => {1857  if (output.statusCode !== 200 && output.statusCode >= 300) {1858    return de_CommandError(output, context);1859  }1860  const contents = (0, import_smithy_client.map)({1861    $metadata: deserializeMetadata(output)1862  });1863  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");1864  const doc = (0, import_smithy_client.take)(data, {1865    NextToken: [, import_smithy_client.expectString, `nextToken`],1866    Replicators: [, (_) => de___listOfReplicatorSummary(_, context), `replicators`]1867  });1868  Object.assign(contents, doc);1869  return contents;1870}, "de_ListReplicatorsCommand");1871var de_ListScramSecretsCommand = /* @__PURE__ */ __name(async (output, context) => {1872  if (output.statusCode !== 200 && output.statusCode >= 300) {1873    return de_CommandError(output, context);1874  }1875  const contents = (0, import_smithy_client.map)({1876    $metadata: deserializeMetadata(output)1877  });1878  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");1879  const doc = (0, import_smithy_client.take)(data, {1880    NextToken: [, import_smithy_client.expectString, `nextToken`],1881    SecretArnList: [, import_smithy_client._json, `secretArnList`]1882  });1883  Object.assign(contents, doc);1884  return contents;1885}, "de_ListScramSecretsCommand");1886var de_ListTagsForResourceCommand = /* @__PURE__ */ __name(async (output, context) => {1887  if (output.statusCode !== 200 && output.statusCode >= 300) {1888    return de_CommandError(output, context);1889  }1890  const contents = (0, import_smithy_client.map)({1891    $metadata: deserializeMetadata(output)1892  });1893  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");1894  const doc = (0, import_smithy_client.take)(data, {1895    Tags: [, import_smithy_client._json, `tags`]1896  });1897  Object.assign(contents, doc);1898  return contents;1899}, "de_ListTagsForResourceCommand");1900var de_ListVpcConnectionsCommand = /* @__PURE__ */ __name(async (output, context) => {1901  if (output.statusCode !== 200 && output.statusCode >= 300) {1902    return de_CommandError(output, context);1903  }1904  const contents = (0, import_smithy_client.map)({1905    $metadata: deserializeMetadata(output)1906  });1907  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");1908  const doc = (0, import_smithy_client.take)(data, {1909    NextToken: [, import_smithy_client.expectString, `nextToken`],1910    VpcConnections: [, (_) => de___listOfVpcConnection(_, context), `vpcConnections`]1911  });1912  Object.assign(contents, doc);1913  return contents;1914}, "de_ListVpcConnectionsCommand");1915var de_PutClusterPolicyCommand = /* @__PURE__ */ __name(async (output, context) => {1916  if (output.statusCode !== 200 && output.statusCode >= 300) {1917    return de_CommandError(output, context);1918  }1919  const contents = (0, import_smithy_client.map)({1920    $metadata: deserializeMetadata(output)1921  });1922  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");1923  const doc = (0, import_smithy_client.take)(data, {1924    CurrentVersion: [, import_smithy_client.expectString, `currentVersion`]1925  });1926  Object.assign(contents, doc);1927  return contents;1928}, "de_PutClusterPolicyCommand");1929var de_RebootBrokerCommand = /* @__PURE__ */ __name(async (output, context) => {1930  if (output.statusCode !== 200 && output.statusCode >= 300) {1931    return de_CommandError(output, context);1932  }1933  const contents = (0, import_smithy_client.map)({1934    $metadata: deserializeMetadata(output)1935  });1936  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");1937  const doc = (0, import_smithy_client.take)(data, {1938    ClusterArn: [, import_smithy_client.expectString, `clusterArn`],1939    ClusterOperationArn: [, import_smithy_client.expectString, `clusterOperationArn`]1940  });1941  Object.assign(contents, doc);1942  return contents;1943}, "de_RebootBrokerCommand");1944var de_RejectClientVpcConnectionCommand = /* @__PURE__ */ __name(async (output, context) => {1945  if (output.statusCode !== 200 && output.statusCode >= 300) {1946    return de_CommandError(output, context);1947  }1948  const contents = (0, import_smithy_client.map)({1949    $metadata: deserializeMetadata(output)1950  });1951  await (0, import_smithy_client.collectBody)(output.body, context);1952  return contents;1953}, "de_RejectClientVpcConnectionCommand");1954var de_TagResourceCommand = /* @__PURE__ */ __name(async (output, context) => {1955  if (output.statusCode !== 204 && output.statusCode >= 300) {1956    return de_CommandError(output, context);1957  }1958  const contents = (0, import_smithy_client.map)({1959    $metadata: deserializeMetadata(output)1960  });1961  await (0, import_smithy_client.collectBody)(output.body, context);1962  return contents;1963}, "de_TagResourceCommand");1964var de_UntagResourceCommand = /* @__PURE__ */ __name(async (output, context) => {1965  if (output.statusCode !== 204 && output.statusCode >= 300) {1966    return de_CommandError(output, context);1967  }1968  const contents = (0, import_smithy_client.map)({1969    $metadata: deserializeMetadata(output)1970  });1971  await (0, import_smithy_client.collectBody)(output.body, context);1972  return contents;1973}, "de_UntagResourceCommand");1974var de_UpdateBrokerCountCommand = /* @__PURE__ */ __name(async (output, context) => {1975  if (output.statusCode !== 200 && output.statusCode >= 300) {1976    return de_CommandError(output, context);1977  }1978  const contents = (0, import_smithy_client.map)({1979    $metadata: deserializeMetadata(output)1980  });1981  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");1982  const doc = (0, import_smithy_client.take)(data, {1983    ClusterArn: [, import_smithy_client.expectString, `clusterArn`],1984    ClusterOperationArn: [, import_smithy_client.expectString, `clusterOperationArn`]1985  });1986  Object.assign(contents, doc);1987  return contents;1988}, "de_UpdateBrokerCountCommand");1989var de_UpdateBrokerStorageCommand = /* @__PURE__ */ __name(async (output, context) => {1990  if (output.statusCode !== 200 && output.statusCode >= 300) {1991    return de_CommandError(output, context);1992  }1993  const contents = (0, import_smithy_client.map)({1994    $metadata: deserializeMetadata(output)1995  });1996  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");1997  const doc = (0, import_smithy_client.take)(data, {1998    ClusterArn: [, import_smithy_client.expectString, `clusterArn`],1999    ClusterOperationArn: [, import_smithy_client.expectString, `clusterOperationArn`]2000  });2001  Object.assign(contents, doc);2002  return contents;2003}, "de_UpdateBrokerStorageCommand");2004var de_UpdateBrokerTypeCommand = /* @__PURE__ */ __name(async (output, context) => {2005  if (output.statusCode !== 200 && output.statusCode >= 300) {2006    return de_CommandError(output, context);2007  }2008  const contents = (0, import_smithy_client.map)({2009    $metadata: deserializeMetadata(output)2010  });2011  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");2012  const doc = (0, import_smithy_client.take)(data, {2013    ClusterArn: [, import_smithy_client.expectString, `clusterArn`],2014    ClusterOperationArn: [, import_smithy_client.expectString, `clusterOperationArn`]2015  });2016  Object.assign(contents, doc);2017  return contents;2018}, "de_UpdateBrokerTypeCommand");2019var de_UpdateClusterConfigurationCommand = /* @__PURE__ */ __name(async (output, context) => {2020  if (output.statusCode !== 200 && output.statusCode >= 300) {2021    return de_CommandError(output, context);2022  }2023  const contents = (0, import_smithy_client.map)({2024    $metadata: deserializeMetadata(output)2025  });2026  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");2027  const doc = (0, import_smithy_client.take)(data, {2028    ClusterArn: [, import_smithy_client.expectString, `clusterArn`],2029    ClusterOperationArn: [, import_smithy_client.expectString, `clusterOperationArn`]2030  });2031  Object.assign(contents, doc);2032  return contents;2033}, "de_UpdateClusterConfigurationCommand");2034var de_UpdateClusterKafkaVersionCommand = /* @__PURE__ */ __name(async (output, context) => {2035  if (output.statusCode !== 200 && output.statusCode >= 300) {2036    return de_CommandError(output, context);2037  }2038  const contents = (0, import_smithy_client.map)({2039    $metadata: deserializeMetadata(output)2040  });2041  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");2042  const doc = (0, import_smithy_client.take)(data, {2043    ClusterArn: [, import_smithy_client.expectString, `clusterArn`],2044    ClusterOperationArn: [, import_smithy_client.expectString, `clusterOperationArn`]2045  });2046  Object.assign(contents, doc);2047  return contents;2048}, "de_UpdateClusterKafkaVersionCommand");2049var de_UpdateConfigurationCommand = /* @__PURE__ */ __name(async (output, context) => {2050  if (output.statusCode !== 200 && output.statusCode >= 300) {2051    return de_CommandError(output, context);2052  }2053  const contents = (0, import_smithy_client.map)({2054    $metadata: deserializeMetadata(output)2055  });2056  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");2057  const doc = (0, import_smithy_client.take)(data, {2058    Arn: [, import_smithy_client.expectString, `arn`],2059    LatestRevision: [, (_) => de_ConfigurationRevision(_, context), `latestRevision`]2060  });2061  Object.assign(contents, doc);2062  return contents;2063}, "de_UpdateConfigurationCommand");2064var de_UpdateConnectivityCommand = /* @__PURE__ */ __name(async (output, context) => {2065  if (output.statusCode !== 200 && output.statusCode >= 300) {2066    return de_CommandError(output, context);2067  }2068  const contents = (0, import_smithy_client.map)({2069    $metadata: deserializeMetadata(output)2070  });2071  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");2072  const doc = (0, import_smithy_client.take)(data, {2073    ClusterArn: [, import_smithy_client.expectString, `clusterArn`],2074    ClusterOperationArn: [, import_smithy_client.expectString, `clusterOperationArn`]2075  });2076  Object.assign(contents, doc);2077  return contents;2078}, "de_UpdateConnectivityCommand");2079var de_UpdateMonitoringCommand = /* @__PURE__ */ __name(async (output, context) => {2080  if (output.statusCode !== 200 && output.statusCode >= 300) {2081    return de_CommandError(output, context);2082  }2083  const contents = (0, import_smithy_client.map)({2084    $metadata: deserializeMetadata(output)2085  });2086  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");2087  const doc = (0, import_smithy_client.take)(data, {2088    ClusterArn: [, import_smithy_client.expectString, `clusterArn`],2089    ClusterOperationArn: [, import_smithy_client.expectString, `clusterOperationArn`]2090  });2091  Object.assign(contents, doc);2092  return contents;2093}, "de_UpdateMonitoringCommand");2094var de_UpdateReplicationInfoCommand = /* @__PURE__ */ __name(async (output, context) => {2095  if (output.statusCode !== 200 && output.statusCode >= 300) {2096    return de_CommandError(output, context);2097  }2098  const contents = (0, import_smithy_client.map)({2099    $metadata: deserializeMetadata(output)2100  });2101  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");2102  const doc = (0, import_smithy_client.take)(data, {2103    ReplicatorArn: [, import_smithy_client.expectString, `replicatorArn`],2104    ReplicatorState: [, import_smithy_client.expectString, `replicatorState`]2105  });2106  Object.assign(contents, doc);2107  return contents;2108}, "de_UpdateReplicationInfoCommand");2109var de_UpdateSecurityCommand = /* @__PURE__ */ __name(async (output, context) => {2110  if (output.statusCode !== 200 && output.statusCode >= 300) {2111    return de_CommandError(output, context);2112  }2113  const contents = (0, import_smithy_client.map)({2114    $metadata: deserializeMetadata(output)2115  });2116  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");2117  const doc = (0, import_smithy_client.take)(data, {2118    ClusterArn: [, import_smithy_client.expectString, `clusterArn`],2119    ClusterOperationArn: [, import_smithy_client.expectString, `clusterOperationArn`]2120  });2121  Object.assign(contents, doc);2122  return contents;2123}, "de_UpdateSecurityCommand");2124var de_UpdateStorageCommand = /* @__PURE__ */ __name(async (output, context) => {2125  if (output.statusCode !== 200 && output.statusCode >= 300) {2126    return de_CommandError(output, context);2127  }2128  const contents = (0, import_smithy_client.map)({2129    $metadata: deserializeMetadata(output)2130  });2131  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");2132  const doc = (0, import_smithy_client.take)(data, {2133    ClusterArn: [, import_smithy_client.expectString, `clusterArn`],2134    ClusterOperationArn: [, import_smithy_client.expectString, `clusterOperationArn`]2135  });2136  Object.assign(contents, doc);2137  return contents;2138}, "de_UpdateStorageCommand");2139var de_CommandError = /* @__PURE__ */ __name(async (output, context) => {2140  const parsedOutput = {2141    ...output,2142    body: await (0, import_core2.parseJsonErrorBody)(output.body, context)2143  };2144  const errorCode = (0, import_core2.loadRestJsonErrorCode)(output, parsedOutput.body);2145  switch (errorCode) {2146    case "BadRequestException":2147    case "com.amazonaws.kafka#BadRequestException":2148      throw await de_BadRequestExceptionRes(parsedOutput, context);2149    case "ForbiddenException":2150    case "com.amazonaws.kafka#ForbiddenException":2151      throw await de_ForbiddenExceptionRes(parsedOutput, context);2152    case "InternalServerErrorException":2153    case "com.amazonaws.kafka#InternalServerErrorException":2154      throw await de_InternalServerErrorExceptionRes(parsedOutput, context);2155    case "NotFoundException":2156    case "com.amazonaws.kafka#NotFoundException":2157      throw await de_NotFoundExceptionRes(parsedOutput, context);2158    case "ServiceUnavailableException":2159    case "com.amazonaws.kafka#ServiceUnavailableException":2160      throw await de_ServiceUnavailableExceptionRes(parsedOutput, context);2161    case "TooManyRequestsException":2162    case "com.amazonaws.kafka#TooManyRequestsException":2163      throw await de_TooManyRequestsExceptionRes(parsedOutput, context);2164    case "UnauthorizedException":2165    case "com.amazonaws.kafka#UnauthorizedException":2166      throw await de_UnauthorizedExceptionRes(parsedOutput, context);2167    case "ConflictException":2168    case "com.amazonaws.kafka#ConflictException":2169      throw await de_ConflictExceptionRes(parsedOutput, context);2170    default:2171      const parsedBody = parsedOutput.body;2172      return throwDefaultError({2173        output,2174        parsedBody,2175        errorCode2176      });2177  }2178}, "de_CommandError");2179var throwDefaultError = (0, import_smithy_client.withBaseException)(KafkaServiceException);2180var de_BadRequestExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => {2181  const contents = (0, import_smithy_client.map)({});2182  const data = parsedOutput.body;2183  const doc = (0, import_smithy_client.take)(data, {2184    InvalidParameter: [, import_smithy_client.expectString, `invalidParameter`],2185    Message: [, import_smithy_client.expectString, `message`]2186  });2187  Object.assign(contents, doc);2188  const exception = new BadRequestException({2189    $metadata: deserializeMetadata(parsedOutput),2190    ...contents2191  });2192  return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);2193}, "de_BadRequestExceptionRes");2194var de_ConflictExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => {2195  const contents = (0, import_smithy_client.map)({});2196  const data = parsedOutput.body;2197  const doc = (0, import_smithy_client.take)(data, {2198    InvalidParameter: [, import_smithy_client.expectString, `invalidParameter`],2199    Message: [, import_smithy_client.expectString, `message`]2200  });2201  Object.assign(contents, doc);2202  const exception = new ConflictException({2203    $metadata: deserializeMetadata(parsedOutput),2204    ...contents2205  });2206  return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);2207}, "de_ConflictExceptionRes");2208var de_ForbiddenExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => {2209  const contents = (0, import_smithy_client.map)({});2210  const data = parsedOutput.body;2211  const doc = (0, import_smithy_client.take)(data, {2212    InvalidParameter: [, import_smithy_client.expectString, `invalidParameter`],2213    Message: [, import_smithy_client.expectString, `message`]2214  });2215  Object.assign(contents, doc);2216  const exception = new ForbiddenException({2217    $metadata: deserializeMetadata(parsedOutput),2218    ...contents2219  });2220  return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);2221}, "de_ForbiddenExceptionRes");2222var de_InternalServerErrorExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => {2223  const contents = (0, import_smithy_client.map)({});2224  const data = parsedOutput.body;2225  const doc = (0, import_smithy_client.take)(data, {2226    InvalidParameter: [, import_smithy_client.expectString, `invalidParameter`],2227    Message: [, import_smithy_client.expectString, `message`]2228  });2229  Object.assign(contents, doc);2230  const exception = new InternalServerErrorException({2231    $metadata: deserializeMetadata(parsedOutput),2232    ...contents2233  });2234  return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);2235}, "de_InternalServerErrorExceptionRes");2236var de_NotFoundExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => {2237  const contents = (0, import_smithy_client.map)({});2238  const data = parsedOutput.body;2239  const doc = (0, import_smithy_client.take)(data, {2240    InvalidParameter: [, import_smithy_client.expectString, `invalidParameter`],2241    Message: [, import_smithy_client.expectString, `message`]2242  });2243  Object.assign(contents, doc);2244  const exception = new NotFoundException({2245    $metadata: deserializeMetadata(parsedOutput),2246    ...contents2247  });2248  return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);2249}, "de_NotFoundExceptionRes");2250var de_ServiceUnavailableExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => {2251  const contents = (0, import_smithy_client.map)({});2252  const data = parsedOutput.body;2253  const doc = (0, import_smithy_client.take)(data, {2254    InvalidParameter: [, import_smithy_client.expectString, `invalidParameter`],2255    Message: [, import_smithy_client.expectString, `message`]2256  });2257  Object.assign(contents, doc);2258  const exception = new ServiceUnavailableException({2259    $metadata: deserializeMetadata(parsedOutput),2260    ...contents2261  });2262  return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);2263}, "de_ServiceUnavailableExceptionRes");2264var de_TooManyRequestsExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => {2265  const contents = (0, import_smithy_client.map)({});2266  const data = parsedOutput.body;2267  const doc = (0, import_smithy_client.take)(data, {2268    InvalidParameter: [, import_smithy_client.expectString, `invalidParameter`],2269    Message: [, import_smithy_client.expectString, `message`]2270  });2271  Object.assign(contents, doc);2272  const exception = new TooManyRequestsException({2273    $metadata: deserializeMetadata(parsedOutput),2274    ...contents2275  });2276  return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);2277}, "de_TooManyRequestsExceptionRes");2278var de_UnauthorizedExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => {2279  const contents = (0, import_smithy_client.map)({});2280  const data = parsedOutput.body;2281  const doc = (0, import_smithy_client.take)(data, {2282    InvalidParameter: [, import_smithy_client.expectString, `invalidParameter`],2283    Message: [, import_smithy_client.expectString, `message`]2284  });2285  Object.assign(contents, doc);2286  const exception = new UnauthorizedException({2287    $metadata: deserializeMetadata(parsedOutput),2288    ...contents2289  });2290  return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);2291}, "de_UnauthorizedExceptionRes");2292var se___listOfBrokerEBSVolumeInfo = /* @__PURE__ */ __name((input, context) => {2293  return input.filter((e) => e != null).map((entry) => {2294    return se_BrokerEBSVolumeInfo(entry, context);2295  });2296}, "se___listOfBrokerEBSVolumeInfo");2297var se___listOfKafkaCluster = /* @__PURE__ */ __name((input, context) => {2298  return input.filter((e) => e != null).map((entry) => {2299    return se_KafkaCluster(entry, context);2300  });2301}, "se___listOfKafkaCluster");2302var se___listOfReplicationInfo = /* @__PURE__ */ __name((input, context) => {2303  return input.filter((e) => e != null).map((entry) => {2304    return se_ReplicationInfo(entry, context);2305  });2306}, "se___listOfReplicationInfo");2307var se___listOfVpcConfig = /* @__PURE__ */ __name((input, context) => {2308  return input.filter((e) => e != null).map((entry) => {2309    return se_VpcConfig(entry, context);2310  });2311}, "se___listOfVpcConfig");2312var se_AmazonMskCluster = /* @__PURE__ */ __name((input, context) => {2313  return (0, import_smithy_client.take)(input, {2314    mskClusterArn: [, , `MskClusterArn`]2315  });2316}, "se_AmazonMskCluster");2317var se_BrokerEBSVolumeInfo = /* @__PURE__ */ __name((input, context) => {2318  return (0, import_smithy_client.take)(input, {2319    kafkaBrokerNodeId: [, , `KafkaBrokerNodeId`],2320    provisionedThroughput: [, (_) => se_ProvisionedThroughput(_, context), `ProvisionedThroughput`],2321    volumeSizeGB: [, , `VolumeSizeGB`]2322  });2323}, "se_BrokerEBSVolumeInfo");2324var se_BrokerLogs = /* @__PURE__ */ __name((input, context) => {2325  return (0, import_smithy_client.take)(input, {2326    cloudWatchLogs: [, (_) => se_CloudWatchLogs(_, context), `CloudWatchLogs`],2327    firehose: [, (_) => se_Firehose(_, context), `Firehose`],2328    s3: [, (_) => se_S3(_, context), `S3`]2329  });2330}, "se_BrokerLogs");2331var se_BrokerNodeGroupInfo = /* @__PURE__ */ __name((input, context) => {2332  return (0, import_smithy_client.take)(input, {2333    brokerAZDistribution: [, , `BrokerAZDistribution`],2334    clientSubnets: [, import_smithy_client._json, `ClientSubnets`],2335    connectivityInfo: [, (_) => se_ConnectivityInfo(_, context), `ConnectivityInfo`],2336    instanceType: [, , `InstanceType`],2337    securityGroups: [, import_smithy_client._json, `SecurityGroups`],2338    storageInfo: [, (_) => se_StorageInfo(_, context), `StorageInfo`],2339    zoneIds: [, import_smithy_client._json, `ZoneIds`]2340  });2341}, "se_BrokerNodeGroupInfo");2342var se_ClientAuthentication = /* @__PURE__ */ __name((input, context) => {2343  return (0, import_smithy_client.take)(input, {2344    sasl: [, (_) => se_Sasl(_, context), `Sasl`],2345    tls: [, (_) => se_Tls(_, context), `Tls`],2346    unauthenticated: [, (_) => se_Unauthenticated(_, context), `Unauthenticated`]2347  });2348}, "se_ClientAuthentication");2349var se_CloudWatchLogs = /* @__PURE__ */ __name((input, context) => {2350  return (0, import_smithy_client.take)(input, {2351    enabled: [, , `Enabled`],2352    logGroup: [, , `LogGroup`]2353  });2354}, "se_CloudWatchLogs");2355var se_ConfigurationInfo = /* @__PURE__ */ __name((input, context) => {2356  return (0, import_smithy_client.take)(input, {2357    arn: [, , `Arn`],2358    revision: [, , `Revision`]2359  });2360}, "se_ConfigurationInfo");2361var se_ConnectivityInfo = /* @__PURE__ */ __name((input, context) => {2362  return (0, import_smithy_client.take)(input, {2363    publicAccess: [, (_) => se_PublicAccess(_, context), `PublicAccess`],2364    vpcConnectivity: [, (_) => se_VpcConnectivity(_, context), `VpcConnectivity`]2365  });2366}, "se_ConnectivityInfo");2367var se_ConsumerGroupReplication = /* @__PURE__ */ __name((input, context) => {2368  return (0, import_smithy_client.take)(input, {2369    consumerGroupsToExclude: [, import_smithy_client._json, `ConsumerGroupsToExclude`],2370    consumerGroupsToReplicate: [, import_smithy_client._json, `ConsumerGroupsToReplicate`],2371    detectAndCopyNewConsumerGroups: [, , `DetectAndCopyNewConsumerGroups`],2372    synchroniseConsumerGroupOffsets: [, , `SynchroniseConsumerGroupOffsets`]2373  });2374}, "se_ConsumerGroupReplication");2375var se_ConsumerGroupReplicationUpdate = /* @__PURE__ */ __name((input, context) => {2376  return (0, import_smithy_client.take)(input, {2377    consumerGroupsToExclude: [, import_smithy_client._json, `ConsumerGroupsToExclude`],2378    consumerGroupsToReplicate: [, import_smithy_client._json, `ConsumerGroupsToReplicate`],2379    detectAndCopyNewConsumerGroups: [, , `DetectAndCopyNewConsumerGroups`],2380    synchroniseConsumerGroupOffsets: [, , `SynchroniseConsumerGroupOffsets`]2381  });2382}, "se_ConsumerGroupReplicationUpdate");2383var se_EBSStorageInfo = /* @__PURE__ */ __name((input, context) => {2384  return (0, import_smithy_client.take)(input, {2385    provisionedThroughput: [, (_) => se_ProvisionedThroughput(_, context), `ProvisionedThroughput`],2386    volumeSize: [, , `VolumeSize`]2387  });2388}, "se_EBSStorageInfo");2389var se_EncryptionAtRest = /* @__PURE__ */ __name((input, context) => {2390  return (0, import_smithy_client.take)(input, {2391    dataVolumeKMSKeyId: [, , `DataVolumeKMSKeyId`]2392  });2393}, "se_EncryptionAtRest");2394var se_EncryptionInfo = /* @__PURE__ */ __name((input, context) => {2395  return (0, import_smithy_client.take)(input, {2396    encryptionAtRest: [, (_) => se_EncryptionAtRest(_, context), `EncryptionAtRest`],2397    encryptionInTransit: [, (_) => se_EncryptionInTransit(_, context), `EncryptionInTransit`]2398  });2399}, "se_EncryptionInfo");2400var se_EncryptionInTransit = /* @__PURE__ */ __name((input, context) => {2401  return (0, import_smithy_client.take)(input, {2402    clientBroker: [, , `ClientBroker`],2403    inCluster: [, , `InCluster`]2404  });2405}, "se_EncryptionInTransit");2406var se_Firehose = /* @__PURE__ */ __name((input, context) => {2407  return (0, import_smithy_client.take)(input, {2408    deliveryStream: [, , `DeliveryStream`],2409    enabled: [, , `Enabled`]2410  });2411}, "se_Firehose");2412var se_Iam = /* @__PURE__ */ __name((input, context) => {2413  return (0, import_smithy_client.take)(input, {2414    enabled: [, , `Enabled`]2415  });2416}, "se_Iam");2417var se_JmxExporterInfo = /* @__PURE__ */ __name((input, context) => {2418  return (0, import_smithy_client.take)(input, {2419    enabledInBroker: [, , `EnabledInBroker`]2420  });2421}, "se_JmxExporterInfo");2422var se_KafkaCluster = /* @__PURE__ */ __name((input, context) => {2423  return (0, import_smithy_client.take)(input, {2424    amazonMskCluster: [, (_) => se_AmazonMskCluster(_, context), `AmazonMskCluster`],2425    vpcConfig: [, (_) => se_KafkaClusterClientVpcConfig(_, context), `VpcConfig`]2426  });2427}, "se_KafkaCluster");2428var se_KafkaClusterClientVpcConfig = /* @__PURE__ */ __name((input, context) => {2429  return (0, import_smithy_client.take)(input, {2430    securityGroupIds: [, import_smithy_client._json, `SecurityGroupIds`],2431    subnetIds: [, import_smithy_client._json, `SubnetIds`]2432  });2433}, "se_KafkaClusterClientVpcConfig");2434var se_LoggingInfo = /* @__PURE__ */ __name((input, context) => {2435  return (0, import_smithy_client.take)(input, {2436    brokerLogs: [, (_) => se_BrokerLogs(_, context), `BrokerLogs`]2437  });2438}, "se_LoggingInfo");2439var se_NodeExporterInfo = /* @__PURE__ */ __name((input, context) => {2440  return (0, import_smithy_client.take)(input, {2441    enabledInBroker: [, , `EnabledInBroker`]2442  });2443}, "se_NodeExporterInfo");2444var se_OpenMonitoringInfo = /* @__PURE__ */ __name((input, context) => {2445  return (0, import_smithy_client.take)(input, {2446    prometheus: [, (_) => se_PrometheusInfo(_, context), `Prometheus`]2447  });2448}, "se_OpenMonitoringInfo");2449var se_PrometheusInfo = /* @__PURE__ */ __name((input, context) => {2450  return (0, import_smithy_client.take)(input, {2451    jmxExporter: [, (_) => se_JmxExporterInfo(_, context), `JmxExporter`],2452    nodeExporter: [, (_) => se_NodeExporterInfo(_, context), `NodeExporter`]2453  });2454}, "se_PrometheusInfo");2455var se_ProvisionedRequest = /* @__PURE__ */ __name((input, context) => {2456  return (0, import_smithy_client.take)(input, {2457    brokerNodeGroupInfo: [, (_) => se_BrokerNodeGroupInfo(_, context), `BrokerNodeGroupInfo`],2458    clientAuthentication: [, (_) => se_ClientAuthentication(_, context), `ClientAuthentication`],2459    configurationInfo: [, (_) => se_ConfigurationInfo(_, context), `ConfigurationInfo`],2460    encryptionInfo: [, (_) => se_EncryptionInfo(_, context), `EncryptionInfo`],2461    enhancedMonitoring: [, , `EnhancedMonitoring`],2462    kafkaVersion: [, , `KafkaVersion`],2463    loggingInfo: [, (_) => se_LoggingInfo(_, context), `LoggingInfo`],2464    numberOfBrokerNodes: [, , `NumberOfBrokerNodes`],2465    openMonitoring: [, (_) => se_OpenMonitoringInfo(_, context), `OpenMonitoring`],2466    storageMode: [, , `StorageMode`]2467  });2468}, "se_ProvisionedRequest");2469var se_ProvisionedThroughput = /* @__PURE__ */ __name((input, context) => {2470  return (0, import_smithy_client.take)(input, {2471    enabled: [, , `Enabled`],2472    volumeThroughput: [, , `VolumeThroughput`]2473  });2474}, "se_ProvisionedThroughput");2475var se_PublicAccess = /* @__PURE__ */ __name((input, context) => {2476  return (0, import_smithy_client.take)(input, {2477    type: [, , `Type`]2478  });2479}, "se_PublicAccess");2480var se_ReplicationInfo = /* @__PURE__ */ __name((input, context) => {2481  return (0, import_smithy_client.take)(input, {2482    consumerGroupReplication: [, (_) => se_ConsumerGroupReplication(_, context), `ConsumerGroupReplication`],2483    sourceKafkaClusterArn: [, , `SourceKafkaClusterArn`],2484    targetCompressionType: [, , `TargetCompressionType`],2485    targetKafkaClusterArn: [, , `TargetKafkaClusterArn`],2486    topicReplication: [, (_) => se_TopicReplication(_, context), `TopicReplication`]2487  });2488}, "se_ReplicationInfo");2489var se_ReplicationStartingPosition = /* @__PURE__ */ __name((input, context) => {2490  return (0, import_smithy_client.take)(input, {2491    type: [, , `Type`]2492  });2493}, "se_ReplicationStartingPosition");2494var se_ReplicationTopicNameConfiguration = /* @__PURE__ */ __name((input, context) => {2495  return (0, import_smithy_client.take)(input, {2496    type: [, , `Type`]2497  });2498}, "se_ReplicationTopicNameConfiguration");2499var se_S3 = /* @__PURE__ */ __name((input, context) => {2500  return (0, import_smithy_client.take)(input, {2501    bucket: [, , `Bucket`],2502    enabled: [, , `Enabled`],2503    prefix: [, , `Prefix`]2504  });2505}, "se_S3");2506var se_Sasl = /* @__PURE__ */ __name((input, context) => {2507  return (0, import_smithy_client.take)(input, {2508    iam: [, (_) => se_Iam(_, context), `Iam`],2509    scram: [, (_) => se_Scram(_, context), `Scram`]2510  });2511}, "se_Sasl");2512var se_Scram = /* @__PURE__ */ __name((input, context) => {2513  return (0, import_smithy_client.take)(input, {2514    enabled: [, , `Enabled`]2515  });2516}, "se_Scram");2517var se_ServerlessClientAuthentication = /* @__PURE__ */ __name((input, context) => {2518  return (0, import_smithy_client.take)(input, {2519    sasl: [, (_) => se_ServerlessSasl(_, context), `Sasl`]2520  });2521}, "se_ServerlessClientAuthentication");2522var se_ServerlessRequest = /* @__PURE__ */ __name((input, context) => {2523  return (0, import_smithy_client.take)(input, {2524    clientAuthentication: [, (_) => se_ServerlessClientAuthentication(_, context), `ClientAuthentication`],2525    vpcConfigs: [, (_) => se___listOfVpcConfig(_, context), `VpcConfigs`]2526  });2527}, "se_ServerlessRequest");2528var se_ServerlessSasl = /* @__PURE__ */ __name((input, context) => {2529  return (0, import_smithy_client.take)(input, {2530    iam: [, (_) => se_Iam(_, context), `Iam`]2531  });2532}, "se_ServerlessSasl");2533var se_StorageInfo = /* @__PURE__ */ __name((input, context) => {2534  return (0, import_smithy_client.take)(input, {2535    ebsStorageInfo: [, (_) => se_EBSStorageInfo(_, context), `EbsStorageInfo`]2536  });2537}, "se_StorageInfo");2538var se_Tls = /* @__PURE__ */ __name((input, context) => {2539  return (0, import_smithy_client.take)(input, {2540    certificateAuthorityArnList: [, import_smithy_client._json, `CertificateAuthorityArnList`],2541    enabled: [, , `Enabled`]2542  });2543}, "se_Tls");2544var se_TopicReplication = /* @__PURE__ */ __name((input, context) => {2545  return (0, import_smithy_client.take)(input, {2546    copyAccessControlListsForTopics: [, , `CopyAccessControlListsForTopics`],2547    copyTopicConfigurations: [, , `CopyTopicConfigurations`],2548    detectAndCopyNewTopics: [, , `DetectAndCopyNewTopics`],2549    startingPosition: [, (_) => se_ReplicationStartingPosition(_, context), `StartingPosition`],2550    topicNameConfiguration: [, (_) => se_ReplicationTopicNameConfiguration(_, context), `TopicNameConfiguration`],2551    topicsToExclude: [, import_smithy_client._json, `TopicsToExclude`],2552    topicsToReplicate: [, import_smithy_client._json, `TopicsToReplicate`]2553  });2554}, "se_TopicReplication");2555var se_TopicReplicationUpdate = /* @__PURE__ */ __name((input, context) => {2556  return (0, import_smithy_client.take)(input, {2557    copyAccessControlListsForTopics: [, , `CopyAccessControlListsForTopics`],2558    copyTopicConfigurations: [, , `CopyTopicConfigurations`],2559    detectAndCopyNewTopics: [, , `DetectAndCopyNewTopics`],2560    topicsToExclude: [, import_smithy_client._json, `TopicsToExclude`],2561    topicsToReplicate: [, import_smithy_client._json, `TopicsToReplicate`]2562  });2563}, "se_TopicReplicationUpdate");2564var se_Unauthenticated = /* @__PURE__ */ __name((input, context) => {2565  return (0, import_smithy_client.take)(input, {2566    enabled: [, , `Enabled`]2567  });2568}, "se_Unauthenticated");2569var se_VpcConfig = /* @__PURE__ */ __name((input, context) => {2570  return (0, import_smithy_client.take)(input, {2571    securityGroupIds: [, import_smithy_client._json, `SecurityGroupIds`],2572    subnetIds: [, import_smithy_client._json, `SubnetIds`]2573  });2574}, "se_VpcConfig");2575var se_VpcConnectivity = /* @__PURE__ */ __name((input, context) => {2576  return (0, import_smithy_client.take)(input, {2577    clientAuthentication: [, (_) => se_VpcConnectivityClientAuthentication(_, context), `ClientAuthentication`]2578  });2579}, "se_VpcConnectivity");2580var se_VpcConnectivityClientAuthentication = /* @__PURE__ */ __name((input, context) => {2581  return (0, import_smithy_client.take)(input, {2582    sasl: [, (_) => se_VpcConnectivitySasl(_, context), `Sasl`],2583    tls: [, (_) => se_VpcConnectivityTls(_, context), `Tls`]2584  });2585}, "se_VpcConnectivityClientAuthentication");2586var se_VpcConnectivityIam = /* @__PURE__ */ __name((input, context) => {2587  return (0, import_smithy_client.take)(input, {2588    enabled: [, , `Enabled`]2589  });2590}, "se_VpcConnectivityIam");2591var se_VpcConnectivitySasl = /* @__PURE__ */ __name((input, context) => {2592  return (0, import_smithy_client.take)(input, {2593    iam: [, (_) => se_VpcConnectivityIam(_, context), `Iam`],2594    scram: [, (_) => se_VpcConnectivityScram(_, context), `Scram`]2595  });2596}, "se_VpcConnectivitySasl");2597var se_VpcConnectivityScram = /* @__PURE__ */ __name((input, context) => {2598  return (0, import_smithy_client.take)(input, {2599    enabled: [, , `Enabled`]2600  });2601}, "se_VpcConnectivityScram");2602var se_VpcConnectivityTls = /* @__PURE__ */ __name((input, context) => {2603  return (0, import_smithy_client.take)(input, {2604    enabled: [, , `Enabled`]2605  });2606}, "se_VpcConnectivityTls");2607var de___listOf__double = /* @__PURE__ */ __name((output, context) => {2608  const retVal = (output || []).filter((e) => e != null).map((entry) => {2609    return (0, import_smithy_client.limitedParseDouble)(entry);2610  });2611  return retVal;2612}, "de___listOf__double");2613var de___listOfBrokerEBSVolumeInfo = /* @__PURE__ */ __name((output, context) => {2614  const retVal = (output || []).filter((e) => e != null).map((entry) => {2615    return de_BrokerEBSVolumeInfo(entry, context);2616  });2617  return retVal;2618}, "de___listOfBrokerEBSVolumeInfo");2619var de___listOfClientVpcConnection = /* @__PURE__ */ __name((output, context) => {2620  const retVal = (output || []).filter((e) => e != null).map((entry) => {2621    return de_ClientVpcConnection(entry, context);2622  });2623  return retVal;2624}, "de___listOfClientVpcConnection");2625var de___listOfCluster = /* @__PURE__ */ __name((output, context) => {2626  const retVal = (output || []).filter((e) => e != null).map((entry) => {2627    return de_Cluster(entry, context);2628  });2629  return retVal;2630}, "de___listOfCluster");2631var de___listOfClusterInfo = /* @__PURE__ */ __name((output, context) => {2632  const retVal = (output || []).filter((e) => e != null).map((entry) => {2633    return de_ClusterInfo(entry, context);2634  });2635  return retVal;2636}, "de___listOfClusterInfo");2637var de___listOfClusterOperationInfo = /* @__PURE__ */ __name((output, context) => {2638  const retVal = (output || []).filter((e) => e != null).map((entry) => {2639    return de_ClusterOperationInfo(entry, context);2640  });2641  return retVal;2642}, "de___listOfClusterOperationInfo");2643var de___listOfClusterOperationStep = /* @__PURE__ */ __name((output, context) => {2644  const retVal = (output || []).filter((e) => e != null).map((entry) => {2645    return de_ClusterOperationStep(entry, context);2646  });2647  return retVal;2648}, "de___listOfClusterOperationStep");2649var de___listOfClusterOperationV2Summary = /* @__PURE__ */ __name((output, context) => {2650  const retVal = (output || []).filter((e) => e != null).map((entry) => {2651    return de_ClusterOperationV2Summary(entry, context);2652  });2653  return retVal;2654}, "de___listOfClusterOperationV2Summary");2655var de___listOfCompatibleKafkaVersion = /* @__PURE__ */ __name((output, context) => {2656  const retVal = (output || []).filter((e) => e != null).map((entry) => {2657    return de_CompatibleKafkaVersion(entry, context);2658  });2659  return retVal;2660}, "de___listOfCompatibleKafkaVersion");2661var de___listOfConfiguration = /* @__PURE__ */ __name((output, context) => {2662  const retVal = (output || []).filter((e) => e != null).map((entry) => {2663    return de_Configuration(entry, context);2664  });2665  return retVal;2666}, "de___listOfConfiguration");2667var de___listOfConfigurationRevision = /* @__PURE__ */ __name((output, context) => {2668  const retVal = (output || []).filter((e) => e != null).map((entry) => {2669    return de_ConfigurationRevision(entry, context);2670  });2671  return retVal;2672}, "de___listOfConfigurationRevision");2673var de___listOfKafkaClusterDescription = /* @__PURE__ */ __name((output, context) => {2674  const retVal = (output || []).filter((e) => e != null).map((entry) => {2675    return de_KafkaClusterDescription(entry, context);2676  });2677  return retVal;2678}, "de___listOfKafkaClusterDescription");2679var de___listOfKafkaClusterSummary = /* @__PURE__ */ __name((output, context) => {2680  const retVal = (output || []).filter((e) => e != null).map((entry) => {2681    return de_KafkaClusterSummary(entry, context);2682  });2683  return retVal;2684}, "de___listOfKafkaClusterSummary");2685var de___listOfKafkaVersion = /* @__PURE__ */ __name((output, context) => {2686  const retVal = (output || []).filter((e) => e != null).map((entry) => {2687    return de_KafkaVersion(entry, context);2688  });2689  return retVal;2690}, "de___listOfKafkaVersion");2691var de___listOfNodeInfo = /* @__PURE__ */ __name((output, context) => {2692  const retVal = (output || []).filter((e) => e != null).map((entry) => {2693    return de_NodeInfo(entry, context);2694  });2695  return retVal;2696}, "de___listOfNodeInfo");2697var de___listOfReplicationInfoDescription = /* @__PURE__ */ __name((output, context) => {2698  const retVal = (output || []).filter((e) => e != null).map((entry) => {2699    return de_ReplicationInfoDescription(entry, context);2700  });2701  return retVal;2702}, "de___listOfReplicationInfoDescription");2703var de___listOfReplicationInfoSummary = /* @__PURE__ */ __name((output, context) => {2704  const retVal = (output || []).filter((e) => e != null).map((entry) => {2705    return de_ReplicationInfoSummary(entry, context);2706  });2707  return retVal;2708}, "de___listOfReplicationInfoSummary");2709var de___listOfReplicatorSummary = /* @__PURE__ */ __name((output, context) => {2710  const retVal = (output || []).filter((e) => e != null).map((entry) => {2711    return de_ReplicatorSummary(entry, context);2712  });2713  return retVal;2714}, "de___listOfReplicatorSummary");2715var de___listOfUnprocessedScramSecret = /* @__PURE__ */ __name((output, context) => {2716  const retVal = (output || []).filter((e) => e != null).map((entry) => {2717    return de_UnprocessedScramSecret(entry, context);2718  });2719  return retVal;2720}, "de___listOfUnprocessedScramSecret");2721var de___listOfVpcConfig = /* @__PURE__ */ __name((output, context) => {2722  const retVal = (output || []).filter((e) => e != null).map((entry) => {2723    return de_VpcConfig(entry, context);2724  });2725  return retVal;2726}, "de___listOfVpcConfig");2727var de___listOfVpcConnection = /* @__PURE__ */ __name((output, context) => {2728  const retVal = (output || []).filter((e) => e != null).map((entry) => {2729    return de_VpcConnection(entry, context);2730  });2731  return retVal;2732}, "de___listOfVpcConnection");2733var de_AmazonMskCluster = /* @__PURE__ */ __name((output, context) => {2734  return (0, import_smithy_client.take)(output, {2735    MskClusterArn: [, import_smithy_client.expectString, `mskClusterArn`]2736  });2737}, "de_AmazonMskCluster");2738var de_BrokerCountUpdateInfo = /* @__PURE__ */ __name((output, context) => {2739  return (0, import_smithy_client.take)(output, {2740    CreatedBrokerIds: [, (_) => de___listOf__double(_, context), `createdBrokerIds`],2741    DeletedBrokerIds: [, (_) => de___listOf__double(_, context), `deletedBrokerIds`]2742  });2743}, "de_BrokerCountUpdateInfo");2744var de_BrokerEBSVolumeInfo = /* @__PURE__ */ __name((output, context) => {2745  return (0, import_smithy_client.take)(output, {2746    KafkaBrokerNodeId: [, import_smithy_client.expectString, `kafkaBrokerNodeId`],2747    ProvisionedThroughput: [, (_) => de_ProvisionedThroughput(_, context), `provisionedThroughput`],2748    VolumeSizeGB: [, import_smithy_client.expectInt32, `volumeSizeGB`]2749  });2750}, "de_BrokerEBSVolumeInfo");2751var de_BrokerLogs = /* @__PURE__ */ __name((output, context) => {2752  return (0, import_smithy_client.take)(output, {2753    CloudWatchLogs: [, (_) => de_CloudWatchLogs(_, context), `cloudWatchLogs`],2754    Firehose: [, (_) => de_Firehose(_, context), `firehose`],2755    S3: [, (_) => de_S3(_, context), `s3`]2756  });2757}, "de_BrokerLogs");2758var de_BrokerNodeGroupInfo = /* @__PURE__ */ __name((output, context) => {2759  return (0, import_smithy_client.take)(output, {2760    BrokerAZDistribution: [, import_smithy_client.expectString, `brokerAZDistribution`],2761    ClientSubnets: [, import_smithy_client._json, `clientSubnets`],2762    ConnectivityInfo: [, (_) => de_ConnectivityInfo(_, context), `connectivityInfo`],2763    InstanceType: [, import_smithy_client.expectString, `instanceType`],2764    SecurityGroups: [, import_smithy_client._json, `securityGroups`],2765    StorageInfo: [, (_) => de_StorageInfo(_, context), `storageInfo`],2766    ZoneIds: [, import_smithy_client._json, `zoneIds`]2767  });2768}, "de_BrokerNodeGroupInfo");2769var de_BrokerNodeInfo = /* @__PURE__ */ __name((output, context) => {2770  return (0, import_smithy_client.take)(output, {2771    AttachedENIId: [, import_smithy_client.expectString, `attachedENIId`],2772    BrokerId: [, import_smithy_client.limitedParseDouble, `brokerId`],2773    ClientSubnet: [, import_smithy_client.expectString, `clientSubnet`],2774    ClientVpcIpAddress: [, import_smithy_client.expectString, `clientVpcIpAddress`],2775    CurrentBrokerSoftwareInfo: [, (_) => de_BrokerSoftwareInfo(_, context), `currentBrokerSoftwareInfo`],2776    Endpoints: [, import_smithy_client._json, `endpoints`]2777  });2778}, "de_BrokerNodeInfo");2779var de_BrokerSoftwareInfo = /* @__PURE__ */ __name((output, context) => {2780  return (0, import_smithy_client.take)(output, {2781    ConfigurationArn: [, import_smithy_client.expectString, `configurationArn`],2782    ConfigurationRevision: [, import_smithy_client.expectLong, `configurationRevision`],2783    KafkaVersion: [, import_smithy_client.expectString, `kafkaVersion`]2784  });2785}, "de_BrokerSoftwareInfo");2786var de_ClientAuthentication = /* @__PURE__ */ __name((output, context) => {2787  return (0, import_smithy_client.take)(output, {2788    Sasl: [, (_) => de_Sasl(_, context), `sasl`],2789    Tls: [, (_) => de_Tls(_, context), `tls`],2790    Unauthenticated: [, (_) => de_Unauthenticated(_, context), `unauthenticated`]2791  });2792}, "de_ClientAuthentication");2793var de_ClientVpcConnection = /* @__PURE__ */ __name((output, context) => {2794  return (0, import_smithy_client.take)(output, {2795    Authentication: [, import_smithy_client.expectString, `authentication`],2796    CreationTime: [, (_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseRfc3339DateTimeWithOffset)(_)), `creationTime`],2797    Owner: [, import_smithy_client.expectString, `owner`],2798    State: [, import_smithy_client.expectString, `state`],2799    VpcConnectionArn: [, import_smithy_client.expectString, `vpcConnectionArn`]2800  });2801}, "de_ClientVpcConnection");2802var de_CloudWatchLogs = /* @__PURE__ */ __name((output, context) => {2803  return (0, import_smithy_client.take)(output, {2804    Enabled: [, import_smithy_client.expectBoolean, `enabled`],2805    LogGroup: [, import_smithy_client.expectString, `logGroup`]2806  });2807}, "de_CloudWatchLogs");2808var de_Cluster = /* @__PURE__ */ __name((output, context) => {2809  return (0, import_smithy_client.take)(output, {2810    ActiveOperationArn: [, import_smithy_client.expectString, `activeOperationArn`],2811    ClusterArn: [, import_smithy_client.expectString, `clusterArn`],2812    ClusterName: [, import_smithy_client.expectString, `clusterName`],2813    ClusterType: [, import_smithy_client.expectString, `clusterType`],2814    CreationTime: [, (_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseRfc3339DateTimeWithOffset)(_)), `creationTime`],2815    CurrentVersion: [, import_smithy_client.expectString, `currentVersion`],2816    Provisioned: [, (_) => de_Provisioned(_, context), `provisioned`],2817    Serverless: [, (_) => de_Serverless(_, context), `serverless`],2818    State: [, import_smithy_client.expectString, `state`],2819    StateInfo: [, (_) => de_StateInfo(_, context), `stateInfo`],2820    Tags: [, import_smithy_client._json, `tags`]2821  });2822}, "de_Cluster");2823var de_ClusterInfo = /* @__PURE__ */ __name((output, context) => {2824  return (0, import_smithy_client.take)(output, {2825    ActiveOperationArn: [, import_smithy_client.expectString, `activeOperationArn`],2826    BrokerNodeGroupInfo: [, (_) => de_BrokerNodeGroupInfo(_, context), `brokerNodeGroupInfo`],2827    ClientAuthentication: [, (_) => de_ClientAuthentication(_, context), `clientAuthentication`],2828    ClusterArn: [, import_smithy_client.expectString, `clusterArn`],2829    ClusterName: [, import_smithy_client.expectString, `clusterName`],2830    CreationTime: [, (_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseRfc3339DateTimeWithOffset)(_)), `creationTime`],2831    CurrentBrokerSoftwareInfo: [, (_) => de_BrokerSoftwareInfo(_, context), `currentBrokerSoftwareInfo`],2832    CurrentVersion: [, import_smithy_client.expectString, `currentVersion`],2833    CustomerActionStatus: [, import_smithy_client.expectString, `customerActionStatus`],2834    EncryptionInfo: [, (_) => de_EncryptionInfo(_, context), `encryptionInfo`],2835    EnhancedMonitoring: [, import_smithy_client.expectString, `enhancedMonitoring`],2836    LoggingInfo: [, (_) => de_LoggingInfo(_, context), `loggingInfo`],2837    NumberOfBrokerNodes: [, import_smithy_client.expectInt32, `numberOfBrokerNodes`],2838    OpenMonitoring: [, (_) => de_OpenMonitoring(_, context), `openMonitoring`],2839    State: [, import_smithy_client.expectString, `state`],2840    StateInfo: [, (_) => de_StateInfo(_, context), `stateInfo`],2841    StorageMode: [, import_smithy_client.expectString, `storageMode`],2842    Tags: [, import_smithy_client._json, `tags`],2843    ZookeeperConnectString: [, import_smithy_client.expectString, `zookeeperConnectString`],2844    ZookeeperConnectStringTls: [, import_smithy_client.expectString, `zookeeperConnectStringTls`]2845  });2846}, "de_ClusterInfo");2847var de_ClusterOperationInfo = /* @__PURE__ */ __name((output, context) => {2848  return (0, import_smithy_client.take)(output, {2849    ClientRequestId: [, import_smithy_client.expectString, `clientRequestId`],2850    ClusterArn: [, import_smithy_client.expectString, `clusterArn`],2851    CreationTime: [, (_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseRfc3339DateTimeWithOffset)(_)), `creationTime`],2852    EndTime: [, (_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseRfc3339DateTimeWithOffset)(_)), `endTime`],2853    ErrorInfo: [, (_) => de_ErrorInfo(_, context), `errorInfo`],2854    OperationArn: [, import_smithy_client.expectString, `operationArn`],2855    OperationState: [, import_smithy_client.expectString, `operationState`],2856    OperationSteps: [, (_) => de___listOfClusterOperationStep(_, context), `operationSteps`],2857    OperationType: [, import_smithy_client.expectString, `operationType`],2858    SourceClusterInfo: [, (_) => de_MutableClusterInfo(_, context), `sourceClusterInfo`],2859    TargetClusterInfo: [, (_) => de_MutableClusterInfo(_, context), `targetClusterInfo`],2860    VpcConnectionInfo: [, (_) => de_VpcConnectionInfo(_, context), `vpcConnectionInfo`]2861  });2862}, "de_ClusterOperationInfo");2863var de_ClusterOperationStep = /* @__PURE__ */ __name((output, context) => {2864  return (0, import_smithy_client.take)(output, {2865    StepInfo: [, (_) => de_ClusterOperationStepInfo(_, context), `stepInfo`],2866    StepName: [, import_smithy_client.expectString, `stepName`]2867  });2868}, "de_ClusterOperationStep");2869var de_ClusterOperationStepInfo = /* @__PURE__ */ __name((output, context) => {2870  return (0, import_smithy_client.take)(output, {2871    StepStatus: [, import_smithy_client.expectString, `stepStatus`]2872  });2873}, "de_ClusterOperationStepInfo");2874var de_ClusterOperationV2 = /* @__PURE__ */ __name((output, context) => {2875  return (0, import_smithy_client.take)(output, {2876    ClusterArn: [, import_smithy_client.expectString, `clusterArn`],2877    ClusterType: [, import_smithy_client.expectString, `clusterType`],2878    EndTime: [, (_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseRfc3339DateTimeWithOffset)(_)), `endTime`],2879    ErrorInfo: [, (_) => de_ErrorInfo(_, context), `errorInfo`],2880    OperationArn: [, import_smithy_client.expectString, `operationArn`],2881    OperationState: [, import_smithy_client.expectString, `operationState`],2882    OperationType: [, import_smithy_client.expectString, `operationType`],2883    Provisioned: [, (_) => de_ClusterOperationV2Provisioned(_, context), `provisioned`],2884    Serverless: [, (_) => de_ClusterOperationV2Serverless(_, context), `serverless`],2885    StartTime: [, (_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseRfc3339DateTimeWithOffset)(_)), `startTime`]2886  });2887}, "de_ClusterOperationV2");2888var de_ClusterOperationV2Provisioned = /* @__PURE__ */ __name((output, context) => {2889  return (0, import_smithy_client.take)(output, {2890    OperationSteps: [, (_) => de___listOfClusterOperationStep(_, context), `operationSteps`],2891    SourceClusterInfo: [, (_) => de_MutableClusterInfo(_, context), `sourceClusterInfo`],2892    TargetClusterInfo: [, (_) => de_MutableClusterInfo(_, context), `targetClusterInfo`],2893    VpcConnectionInfo: [, (_) => de_VpcConnectionInfo(_, context), `vpcConnectionInfo`]2894  });2895}, "de_ClusterOperationV2Provisioned");2896var de_ClusterOperationV2Serverless = /* @__PURE__ */ __name((output, context) => {2897  return (0, import_smithy_client.take)(output, {2898    VpcConnectionInfo: [, (_) => de_VpcConnectionInfoServerless(_, context), `vpcConnectionInfo`]2899  });2900}, "de_ClusterOperationV2Serverless");2901var de_ClusterOperationV2Summary = /* @__PURE__ */ __name((output, context) => {2902  return (0, import_smithy_client.take)(output, {2903    ClusterArn: [, import_smithy_client.expectString, `clusterArn`],2904    ClusterType: [, import_smithy_client.expectString, `clusterType`],2905    EndTime: [, (_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseRfc3339DateTimeWithOffset)(_)), `endTime`],2906    OperationArn: [, import_smithy_client.expectString, `operationArn`],2907    OperationState: [, import_smithy_client.expectString, `operationState`],2908    OperationType: [, import_smithy_client.expectString, `operationType`],2909    StartTime: [, (_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseRfc3339DateTimeWithOffset)(_)), `startTime`]2910  });2911}, "de_ClusterOperationV2Summary");2912var de_CompatibleKafkaVersion = /* @__PURE__ */ __name((output, context) => {2913  return (0, import_smithy_client.take)(output, {2914    SourceVersion: [, import_smithy_client.expectString, `sourceVersion`],2915    TargetVersions: [, import_smithy_client._json, `targetVersions`]2916  });2917}, "de_CompatibleKafkaVersion");2918var de_Configuration = /* @__PURE__ */ __name((output, context) => {2919  return (0, import_smithy_client.take)(output, {2920    Arn: [, import_smithy_client.expectString, `arn`],2921    CreationTime: [, (_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseRfc3339DateTimeWithOffset)(_)), `creationTime`],2922    Description: [, import_smithy_client.expectString, `description`],2923    KafkaVersions: [, import_smithy_client._json, `kafkaVersions`],2924    LatestRevision: [, (_) => de_ConfigurationRevision(_, context), `latestRevision`],2925    Name: [, import_smithy_client.expectString, `name`],2926    State: [, import_smithy_client.expectString, `state`]2927  });2928}, "de_Configuration");2929var de_ConfigurationInfo = /* @__PURE__ */ __name((output, context) => {2930  return (0, import_smithy_client.take)(output, {2931    Arn: [, import_smithy_client.expectString, `arn`],2932    Revision: [, import_smithy_client.expectLong, `revision`]2933  });2934}, "de_ConfigurationInfo");2935var de_ConfigurationRevision = /* @__PURE__ */ __name((output, context) => {2936  return (0, import_smithy_client.take)(output, {2937    CreationTime: [, (_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseRfc3339DateTimeWithOffset)(_)), `creationTime`],2938    Description: [, import_smithy_client.expectString, `description`],2939    Revision: [, import_smithy_client.expectLong, `revision`]2940  });2941}, "de_ConfigurationRevision");2942var de_ConnectivityInfo = /* @__PURE__ */ __name((output, context) => {2943  return (0, import_smithy_client.take)(output, {2944    PublicAccess: [, (_) => de_PublicAccess(_, context), `publicAccess`],2945    VpcConnectivity: [, (_) => de_VpcConnectivity(_, context), `vpcConnectivity`]2946  });2947}, "de_ConnectivityInfo");2948var de_ConsumerGroupReplication = /* @__PURE__ */ __name((output, context) => {2949  return (0, import_smithy_client.take)(output, {2950    ConsumerGroupsToExclude: [, import_smithy_client._json, `consumerGroupsToExclude`],2951    ConsumerGroupsToReplicate: [, import_smithy_client._json, `consumerGroupsToReplicate`],2952    DetectAndCopyNewConsumerGroups: [, import_smithy_client.expectBoolean, `detectAndCopyNewConsumerGroups`],2953    SynchroniseConsumerGroupOffsets: [, import_smithy_client.expectBoolean, `synchroniseConsumerGroupOffsets`]2954  });2955}, "de_ConsumerGroupReplication");2956var de_ControllerNodeInfo = /* @__PURE__ */ __name((output, context) => {2957  return (0, import_smithy_client.take)(output, {2958    Endpoints: [, import_smithy_client._json, `endpoints`]2959  });2960}, "de_ControllerNodeInfo");2961var de_EBSStorageInfo = /* @__PURE__ */ __name((output, context) => {2962  return (0, import_smithy_client.take)(output, {2963    ProvisionedThroughput: [, (_) => de_ProvisionedThroughput(_, context), `provisionedThroughput`],2964    VolumeSize: [, import_smithy_client.expectInt32, `volumeSize`]2965  });2966}, "de_EBSStorageInfo");2967var de_EncryptionAtRest = /* @__PURE__ */ __name((output, context) => {2968  return (0, import_smithy_client.take)(output, {2969    DataVolumeKMSKeyId: [, import_smithy_client.expectString, `dataVolumeKMSKeyId`]2970  });2971}, "de_EncryptionAtRest");2972var de_EncryptionInfo = /* @__PURE__ */ __name((output, context) => {2973  return (0, import_smithy_client.take)(output, {2974    EncryptionAtRest: [, (_) => de_EncryptionAtRest(_, context), `encryptionAtRest`],2975    EncryptionInTransit: [, (_) => de_EncryptionInTransit(_, context), `encryptionInTransit`]2976  });2977}, "de_EncryptionInfo");2978var de_EncryptionInTransit = /* @__PURE__ */ __name((output, context) => {2979  return (0, import_smithy_client.take)(output, {2980    ClientBroker: [, import_smithy_client.expectString, `clientBroker`],2981    InCluster: [, import_smithy_client.expectBoolean, `inCluster`]2982  });2983}, "de_EncryptionInTransit");2984var de_ErrorInfo = /* @__PURE__ */ __name((output, context) => {2985  return (0, import_smithy_client.take)(output, {2986    ErrorCode: [, import_smithy_client.expectString, `errorCode`],2987    ErrorString: [, import_smithy_client.expectString, `errorString`]2988  });2989}, "de_ErrorInfo");2990var de_Firehose = /* @__PURE__ */ __name((output, context) => {2991  return (0, import_smithy_client.take)(output, {2992    DeliveryStream: [, import_smithy_client.expectString, `deliveryStream`],2993    Enabled: [, import_smithy_client.expectBoolean, `enabled`]2994  });2995}, "de_Firehose");2996var de_Iam = /* @__PURE__ */ __name((output, context) => {2997  return (0, import_smithy_client.take)(output, {2998    Enabled: [, import_smithy_client.expectBoolean, `enabled`]2999  });3000}, "de_Iam");3001var de_JmxExporter = /* @__PURE__ */ __name((output, context) => {3002  return (0, import_smithy_client.take)(output, {3003    EnabledInBroker: [, import_smithy_client.expectBoolean, `enabledInBroker`]3004  });3005}, "de_JmxExporter");3006var de_JmxExporterInfo = /* @__PURE__ */ __name((output, context) => {3007  return (0, import_smithy_client.take)(output, {3008    EnabledInBroker: [, import_smithy_client.expectBoolean, `enabledInBroker`]3009  });3010}, "de_JmxExporterInfo");3011var de_KafkaClusterClientVpcConfig = /* @__PURE__ */ __name((output, context) => {3012  return (0, import_smithy_client.take)(output, {3013    SecurityGroupIds: [, import_smithy_client._json, `securityGroupIds`],3014    SubnetIds: [, import_smithy_client._json, `subnetIds`]3015  });3016}, "de_KafkaClusterClientVpcConfig");3017var de_KafkaClusterDescription = /* @__PURE__ */ __name((output, context) => {3018  return (0, import_smithy_client.take)(output, {3019    AmazonMskCluster: [, (_) => de_AmazonMskCluster(_, context), `amazonMskCluster`],3020    KafkaClusterAlias: [, import_smithy_client.expectString, `kafkaClusterAlias`],3021    VpcConfig: [, (_) => de_KafkaClusterClientVpcConfig(_, context), `vpcConfig`]3022  });3023}, "de_KafkaClusterDescription");3024var de_KafkaClusterSummary = /* @__PURE__ */ __name((output, context) => {3025  return (0, import_smithy_client.take)(output, {3026    AmazonMskCluster: [, (_) => de_AmazonMskCluster(_, context), `amazonMskCluster`],3027    KafkaClusterAlias: [, import_smithy_client.expectString, `kafkaClusterAlias`]3028  });3029}, "de_KafkaClusterSummary");3030var de_KafkaVersion = /* @__PURE__ */ __name((output, context) => {3031  return (0, import_smithy_client.take)(output, {3032    Status: [, import_smithy_client.expectString, `status`],3033    Version: [, import_smithy_client.expectString, `version`]3034  });3035}, "de_KafkaVersion");3036var de_LoggingInfo = /* @__PURE__ */ __name((output, context) => {3037  return (0, import_smithy_client.take)(output, {3038    BrokerLogs: [, (_) => de_BrokerLogs(_, context), `brokerLogs`]3039  });3040}, "de_LoggingInfo");3041var de_MutableClusterInfo = /* @__PURE__ */ __name((output, context) => {3042  return (0, import_smithy_client.take)(output, {3043    BrokerCountUpdateInfo: [, (_) => de_BrokerCountUpdateInfo(_, context), `brokerCountUpdateInfo`],3044    BrokerEBSVolumeInfo: [, (_) => de___listOfBrokerEBSVolumeInfo(_, context), `brokerEBSVolumeInfo`],3045    ClientAuthentication: [, (_) => de_ClientAuthentication(_, context), `clientAuthentication`],3046    ConfigurationInfo: [, (_) => de_ConfigurationInfo(_, context), `configurationInfo`],3047    ConnectivityInfo: [, (_) => de_ConnectivityInfo(_, context), `connectivityInfo`],3048    EncryptionInfo: [, (_) => de_EncryptionInfo(_, context), `encryptionInfo`],3049    EnhancedMonitoring: [, import_smithy_client.expectString, `enhancedMonitoring`],3050    InstanceType: [, import_smithy_client.expectString, `instanceType`],3051    KafkaVersion: [, import_smithy_client.expectString, `kafkaVersion`],3052    LoggingInfo: [, (_) => de_LoggingInfo(_, context), `loggingInfo`],3053    NumberOfBrokerNodes: [, import_smithy_client.expectInt32, `numberOfBrokerNodes`],3054    OpenMonitoring: [, (_) => de_OpenMonitoring(_, context), `openMonitoring`],3055    StorageMode: [, import_smithy_client.expectString, `storageMode`]3056  });3057}, "de_MutableClusterInfo");3058var de_NodeExporter = /* @__PURE__ */ __name((output, context) => {3059  return (0, import_smithy_client.take)(output, {3060    EnabledInBroker: [, import_smithy_client.expectBoolean, `enabledInBroker`]3061  });3062}, "de_NodeExporter");3063var de_NodeExporterInfo = /* @__PURE__ */ __name((output, context) => {3064  return (0, import_smithy_client.take)(output, {3065    EnabledInBroker: [, import_smithy_client.expectBoolean, `enabledInBroker`]3066  });3067}, "de_NodeExporterInfo");3068var de_NodeInfo = /* @__PURE__ */ __name((output, context) => {3069  return (0, import_smithy_client.take)(output, {3070    AddedToClusterTime: [, import_smithy_client.expectString, `addedToClusterTime`],3071    BrokerNodeInfo: [, (_) => de_BrokerNodeInfo(_, context), `brokerNodeInfo`],3072    ControllerNodeInfo: [, (_) => de_ControllerNodeInfo(_, context), `controllerNodeInfo`],3073    InstanceType: [, import_smithy_client.expectString, `instanceType`],3074    NodeARN: [, import_smithy_client.expectString, `nodeARN`],3075    NodeType: [, import_smithy_client.expectString, `nodeType`],3076    ZookeeperNodeInfo: [, (_) => de_ZookeeperNodeInfo(_, context), `zookeeperNodeInfo`]3077  });3078}, "de_NodeInfo");3079var de_OpenMonitoring = /* @__PURE__ */ __name((output, context) => {3080  return (0, import_smithy_client.take)(output, {3081    Prometheus: [, (_) => de_Prometheus(_, context), `prometheus`]3082  });3083}, "de_OpenMonitoring");3084var de_OpenMonitoringInfo = /* @__PURE__ */ __name((output, context) => {3085  return (0, import_smithy_client.take)(output, {3086    Prometheus: [, (_) => de_PrometheusInfo(_, context), `prometheus`]3087  });3088}, "de_OpenMonitoringInfo");3089var de_Prometheus = /* @__PURE__ */ __name((output, context) => {3090  return (0, import_smithy_client.take)(output, {3091    JmxExporter: [, (_) => de_JmxExporter(_, context), `jmxExporter`],3092    NodeExporter: [, (_) => de_NodeExporter(_, context), `nodeExporter`]3093  });3094}, "de_Prometheus");3095var de_PrometheusInfo = /* @__PURE__ */ __name((output, context) => {3096  return (0, import_smithy_client.take)(output, {3097    JmxExporter: [, (_) => de_JmxExporterInfo(_, context), `jmxExporter`],3098    NodeExporter: [, (_) => de_NodeExporterInfo(_, context), `nodeExporter`]3099  });3100}, "de_PrometheusInfo");3101var de_Provisioned = /* @__PURE__ */ __name((output, context) => {3102  return (0, import_smithy_client.take)(output, {3103    BrokerNodeGroupInfo: [, (_) => de_BrokerNodeGroupInfo(_, context), `brokerNodeGroupInfo`],3104    ClientAuthentication: [, (_) => de_ClientAuthentication(_, context), `clientAuthentication`],3105    CurrentBrokerSoftwareInfo: [, (_) => de_BrokerSoftwareInfo(_, context), `currentBrokerSoftwareInfo`],3106    CustomerActionStatus: [, import_smithy_client.expectString, `customerActionStatus`],3107    EncryptionInfo: [, (_) => de_EncryptionInfo(_, context), `encryptionInfo`],3108    EnhancedMonitoring: [, import_smithy_client.expectString, `enhancedMonitoring`],3109    LoggingInfo: [, (_) => de_LoggingInfo(_, context), `loggingInfo`],3110    NumberOfBrokerNodes: [, import_smithy_client.expectInt32, `numberOfBrokerNodes`],3111    OpenMonitoring: [, (_) => de_OpenMonitoringInfo(_, context), `openMonitoring`],3112    StorageMode: [, import_smithy_client.expectString, `storageMode`],3113    ZookeeperConnectString: [, import_smithy_client.expectString, `zookeeperConnectString`],3114    ZookeeperConnectStringTls: [, import_smithy_client.expectString, `zookeeperConnectStringTls`]3115  });3116}, "de_Provisioned");3117var de_ProvisionedThroughput = /* @__PURE__ */ __name((output, context) => {3118  return (0, import_smithy_client.take)(output, {3119    Enabled: [, import_smithy_client.expectBoolean, `enabled`],3120    VolumeThroughput: [, import_smithy_client.expectInt32, `volumeThroughput`]3121  });3122}, "de_ProvisionedThroughput");3123var de_PublicAccess = /* @__PURE__ */ __name((output, context) => {3124  return (0, import_smithy_client.take)(output, {3125    Type: [, import_smithy_client.expectString, `type`]3126  });3127}, "de_PublicAccess");3128var de_ReplicationInfoDescription = /* @__PURE__ */ __name((output, context) => {3129  return (0, import_smithy_client.take)(output, {3130    ConsumerGroupReplication: [, (_) => de_ConsumerGroupReplication(_, context), `consumerGroupReplication`],3131    SourceKafkaClusterAlias: [, import_smithy_client.expectString, `sourceKafkaClusterAlias`],3132    TargetCompressionType: [, import_smithy_client.expectString, `targetCompressionType`],3133    TargetKafkaClusterAlias: [, import_smithy_client.expectString, `targetKafkaClusterAlias`],3134    TopicReplication: [, (_) => de_TopicReplication(_, context), `topicReplication`]3135  });3136}, "de_ReplicationInfoDescription");3137var de_ReplicationInfoSummary = /* @__PURE__ */ __name((output, context) => {3138  return (0, import_smithy_client.take)(output, {3139    SourceKafkaClusterAlias: [, import_smithy_client.expectString, `sourceKafkaClusterAlias`],3140    TargetKafkaClusterAlias: [, import_smithy_client.expectString, `targetKafkaClusterAlias`]3141  });3142}, "de_ReplicationInfoSummary");3143var de_ReplicationStartingPosition = /* @__PURE__ */ __name((output, context) => {3144  return (0, import_smithy_client.take)(output, {3145    Type: [, import_smithy_client.expectString, `type`]3146  });3147}, "de_ReplicationStartingPosition");3148var de_ReplicationStateInfo = /* @__PURE__ */ __name((output, context) => {3149  return (0, import_smithy_client.take)(output, {3150    Code: [, import_smithy_client.expectString, `code`],3151    Message: [, import_smithy_client.expectString, `message`]3152  });3153}, "de_ReplicationStateInfo");3154var de_ReplicationTopicNameConfiguration = /* @__PURE__ */ __name((output, context) => {3155  return (0, import_smithy_client.take)(output, {3156    Type: [, import_smithy_client.expectString, `type`]3157  });3158}, "de_ReplicationTopicNameConfiguration");3159var de_ReplicatorSummary = /* @__PURE__ */ __name((output, context) => {3160  return (0, import_smithy_client.take)(output, {3161    CreationTime: [, (_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseRfc3339DateTimeWithOffset)(_)), `creationTime`],3162    CurrentVersion: [, import_smithy_client.expectString, `currentVersion`],3163    IsReplicatorReference: [, import_smithy_client.expectBoolean, `isReplicatorReference`],3164    KafkaClustersSummary: [, (_) => de___listOfKafkaClusterSummary(_, context), `kafkaClustersSummary`],3165    ReplicationInfoSummaryList: [3166      ,3167      (_) => de___listOfReplicationInfoSummary(_, context),3168      `replicationInfoSummaryList`3169    ],3170    ReplicatorArn: [, import_smithy_client.expectString, `replicatorArn`],3171    ReplicatorName: [, import_smithy_client.expectString, `replicatorName`],3172    ReplicatorResourceArn: [, import_smithy_client.expectString, `replicatorResourceArn`],3173    ReplicatorState: [, import_smithy_client.expectString, `replicatorState`]3174  });3175}, "de_ReplicatorSummary");3176var de_S3 = /* @__PURE__ */ __name((output, context) => {3177  return (0, import_smithy_client.take)(output, {3178    Bucket: [, import_smithy_client.expectString, `bucket`],3179    Enabled: [, import_smithy_client.expectBoolean, `enabled`],3180    Prefix: [, import_smithy_client.expectString, `prefix`]3181  });3182}, "de_S3");3183var de_Sasl = /* @__PURE__ */ __name((output, context) => {3184  return (0, import_smithy_client.take)(output, {3185    Iam: [, (_) => de_Iam(_, context), `iam`],3186    Scram: [, (_) => de_Scram(_, context), `scram`]3187  });3188}, "de_Sasl");3189var de_Scram = /* @__PURE__ */ __name((output, context) => {3190  return (0, import_smithy_client.take)(output, {3191    Enabled: [, import_smithy_client.expectBoolean, `enabled`]3192  });3193}, "de_Scram");3194var de_Serverless = /* @__PURE__ */ __name((output, context) => {3195  return (0, import_smithy_client.take)(output, {3196    ClientAuthentication: [, (_) => de_ServerlessClientAuthentication(_, context), `clientAuthentication`],3197    VpcConfigs: [, (_) => de___listOfVpcConfig(_, context), `vpcConfigs`]3198  });3199}, "de_Serverless");3200var de_ServerlessClientAuthentication = /* @__PURE__ */ __name((output, context) => {3201  return (0, import_smithy_client.take)(output, {3202    Sasl: [, (_) => de_ServerlessSasl(_, context), `sasl`]3203  });3204}, "de_ServerlessClientAuthentication");3205var de_ServerlessSasl = /* @__PURE__ */ __name((output, context) => {3206  return (0, import_smithy_client.take)(output, {3207    Iam: [, (_) => de_Iam(_, context), `iam`]3208  });3209}, "de_ServerlessSasl");3210var de_StateInfo = /* @__PURE__ */ __name((output, context) => {3211  return (0, import_smithy_client.take)(output, {3212    Code: [, import_smithy_client.expectString, `code`],3213    Message: [, import_smithy_client.expectString, `message`]3214  });3215}, "de_StateInfo");3216var de_StorageInfo = /* @__PURE__ */ __name((output, context) => {3217  return (0, import_smithy_client.take)(output, {3218    EbsStorageInfo: [, (_) => de_EBSStorageInfo(_, context), `ebsStorageInfo`]3219  });3220}, "de_StorageInfo");3221var de_Tls = /* @__PURE__ */ __name((output, context) => {3222  return (0, import_smithy_client.take)(output, {3223    CertificateAuthorityArnList: [, import_smithy_client._json, `certificateAuthorityArnList`],3224    Enabled: [, import_smithy_client.expectBoolean, `enabled`]3225  });3226}, "de_Tls");3227var de_TopicReplication = /* @__PURE__ */ __name((output, context) => {3228  return (0, import_smithy_client.take)(output, {3229    CopyAccessControlListsForTopics: [, import_smithy_client.expectBoolean, `copyAccessControlListsForTopics`],3230    CopyTopicConfigurations: [, import_smithy_client.expectBoolean, `copyTopicConfigurations`],3231    DetectAndCopyNewTopics: [, import_smithy_client.expectBoolean, `detectAndCopyNewTopics`],3232    StartingPosition: [, (_) => de_ReplicationStartingPosition(_, context), `startingPosition`],3233    TopicNameConfiguration: [, (_) => de_ReplicationTopicNameConfiguration(_, context), `topicNameConfiguration`],3234    TopicsToExclude: [, import_smithy_client._json, `topicsToExclude`],3235    TopicsToReplicate: [, import_smithy_client._json, `topicsToReplicate`]3236  });3237}, "de_TopicReplication");3238var de_Unauthenticated = /* @__PURE__ */ __name((output, context) => {3239  return (0, import_smithy_client.take)(output, {3240    Enabled: [, import_smithy_client.expectBoolean, `enabled`]3241  });3242}, "de_Unauthenticated");3243var de_UnprocessedScramSecret = /* @__PURE__ */ __name((output, context) => {3244  return (0, import_smithy_client.take)(output, {3245    ErrorCode: [, import_smithy_client.expectString, `errorCode`],3246    ErrorMessage: [, import_smithy_client.expectString, `errorMessage`],3247    SecretArn: [, import_smithy_client.expectString, `secretArn`]3248  });3249}, "de_UnprocessedScramSecret");3250var de_UserIdentity = /* @__PURE__ */ __name((output, context) => {3251  return (0, import_smithy_client.take)(output, {3252    PrincipalId: [, import_smithy_client.expectString, `principalId`],3253    Type: [, import_smithy_client.expectString, `type`]3254  });3255}, "de_UserIdentity");3256var de_VpcConfig = /* @__PURE__ */ __name((output, context) => {3257  return (0, import_smithy_client.take)(output, {3258    SecurityGroupIds: [, import_smithy_client._json, `securityGroupIds`],3259    SubnetIds: [, import_smithy_client._json, `subnetIds`]3260  });3261}, "de_VpcConfig");3262var de_VpcConnection = /* @__PURE__ */ __name((output, context) => {3263  return (0, import_smithy_client.take)(output, {3264    Authentication: [, import_smithy_client.expectString, `authentication`],3265    CreationTime: [, (_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseRfc3339DateTimeWithOffset)(_)), `creationTime`],3266    State: [, import_smithy_client.expectString, `state`],3267    TargetClusterArn: [, import_smithy_client.expectString, `targetClusterArn`],3268    VpcConnectionArn: [, import_smithy_client.expectString, `vpcConnectionArn`],3269    VpcId: [, import_smithy_client.expectString, `vpcId`]3270  });3271}, "de_VpcConnection");3272var de_VpcConnectionInfo = /* @__PURE__ */ __name((output, context) => {3273  return (0, import_smithy_client.take)(output, {3274    CreationTime: [, (_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseRfc3339DateTimeWithOffset)(_)), `creationTime`],3275    Owner: [, import_smithy_client.expectString, `owner`],3276    UserIdentity: [, (_) => de_UserIdentity(_, context), `userIdentity`],3277    VpcConnectionArn: [, import_smithy_client.expectString, `vpcConnectionArn`]3278  });3279}, "de_VpcConnectionInfo");3280var de_VpcConnectionInfoServerless = /* @__PURE__ */ __name((output, context) => {3281  return (0, import_smithy_client.take)(output, {3282    CreationTime: [, (_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseRfc3339DateTimeWithOffset)(_)), `creationTime`],3283    Owner: [, import_smithy_client.expectString, `owner`],3284    UserIdentity: [, (_) => de_UserIdentity(_, context), `userIdentity`],3285    VpcConnectionArn: [, import_smithy_client.expectString, `vpcConnectionArn`]3286  });3287}, "de_VpcConnectionInfoServerless");3288var de_VpcConnectivity = /* @__PURE__ */ __name((output, context) => {3289  return (0, import_smithy_client.take)(output, {3290    ClientAuthentication: [, (_) => de_VpcConnectivityClientAuthentication(_, context), `clientAuthentication`]3291  });3292}, "de_VpcConnectivity");3293var de_VpcConnectivityClientAuthentication = /* @__PURE__ */ __name((output, context) => {3294  return (0, import_smithy_client.take)(output, {3295    Sasl: [, (_) => de_VpcConnectivitySasl(_, context), `sasl`],3296    Tls: [, (_) => de_VpcConnectivityTls(_, context), `tls`]3297  });3298}, "de_VpcConnectivityClientAuthentication");3299var de_VpcConnectivityIam = /* @__PURE__ */ __name((output, context) => {3300  return (0, import_smithy_client.take)(output, {3301    Enabled: [, import_smithy_client.expectBoolean, `enabled`]3302  });3303}, "de_VpcConnectivityIam");3304var de_VpcConnectivitySasl = /* @__PURE__ */ __name((output, context) => {3305  return (0, import_smithy_client.take)(output, {3306    Iam: [, (_) => de_VpcConnectivityIam(_, context), `iam`],3307    Scram: [, (_) => de_VpcConnectivityScram(_, context), `scram`]3308  });3309}, "de_VpcConnectivitySasl");3310var de_VpcConnectivityScram = /* @__PURE__ */ __name((output, context) => {3311  return (0, import_smithy_client.take)(output, {3312    Enabled: [, import_smithy_client.expectBoolean, `enabled`]3313  });3314}, "de_VpcConnectivityScram");3315var de_VpcConnectivityTls = /* @__PURE__ */ __name((output, context) => {3316  return (0, import_smithy_client.take)(output, {3317    Enabled: [, import_smithy_client.expectBoolean, `enabled`]3318  });3319}, "de_VpcConnectivityTls");3320var de_ZookeeperNodeInfo = /* @__PURE__ */ __name((output, context) => {3321  return (0, import_smithy_client.take)(output, {3322    AttachedENIId: [, import_smithy_client.expectString, `attachedENIId`],3323    ClientVpcIpAddress: [, import_smithy_client.expectString, `clientVpcIpAddress`],3324    Endpoints: [, import_smithy_client._json, `endpoints`],3325    ZookeeperId: [, import_smithy_client.limitedParseDouble, `zookeeperId`],3326    ZookeeperVersion: [, import_smithy_client.expectString, `zookeeperVersion`]3327  });3328}, "de_ZookeeperNodeInfo");3329var deserializeMetadata = /* @__PURE__ */ __name((output) => ({3330  httpStatusCode: output.statusCode,3331  requestId: output.headers["x-amzn-requestid"] ?? output.headers["x-amzn-request-id"] ?? output.headers["x-amz-request-id"],3332  extendedRequestId: output.headers["x-amz-id-2"],3333  cfId: output.headers["x-amz-cf-id"]3334}), "deserializeMetadata");3335var _CA = "ClusterArn";3336var _CNF = "ClusterNameFilter";3337var _CTF = "ClusterTypeFilter";3338var _CV = "CurrentVersion";3339var _MR = "MaxResults";3340var _NT = "NextToken";3341var _RNF = "ReplicatorNameFilter";3342var _TK = "TagKeys";3343var _cA = "clusterArn";3344var _cNF = "clusterNameFilter";3345var _cTF = "clusterTypeFilter";3346var _cV = "currentVersion";3347var _mR = "maxResults";3348var _nT = "nextToken";3349var _rNF = "replicatorNameFilter";3350var _tK = "tagKeys";3351 3352// src/commands/BatchAssociateScramSecretCommand.ts3353var BatchAssociateScramSecretCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {3354  return [3355    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),3356    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())3357  ];3358}).s("Kafka", "BatchAssociateScramSecret", {}).n("KafkaClient", "BatchAssociateScramSecretCommand").f(void 0, void 0).ser(se_BatchAssociateScramSecretCommand).de(de_BatchAssociateScramSecretCommand).build() {3359  static {3360    __name(this, "BatchAssociateScramSecretCommand");3361  }3362};3363 3364// src/commands/BatchDisassociateScramSecretCommand.ts3365 3366 3367 3368var BatchDisassociateScramSecretCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {3369  return [3370    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),3371    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())3372  ];3373}).s("Kafka", "BatchDisassociateScramSecret", {}).n("KafkaClient", "BatchDisassociateScramSecretCommand").f(void 0, void 0).ser(se_BatchDisassociateScramSecretCommand).de(de_BatchDisassociateScramSecretCommand).build() {3374  static {3375    __name(this, "BatchDisassociateScramSecretCommand");3376  }3377};3378 3379// src/commands/CreateClusterCommand.ts3380 3381 3382 3383var CreateClusterCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {3384  return [3385    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),3386    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())3387  ];3388}).s("Kafka", "CreateCluster", {}).n("KafkaClient", "CreateClusterCommand").f(void 0, void 0).ser(se_CreateClusterCommand).de(de_CreateClusterCommand).build() {3389  static {3390    __name(this, "CreateClusterCommand");3391  }3392};3393 3394// src/commands/CreateClusterV2Command.ts3395 3396 3397 3398var CreateClusterV2Command = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {3399  return [3400    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),3401    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())3402  ];3403}).s("Kafka", "CreateClusterV2", {}).n("KafkaClient", "CreateClusterV2Command").f(void 0, void 0).ser(se_CreateClusterV2Command).de(de_CreateClusterV2Command).build() {3404  static {3405    __name(this, "CreateClusterV2Command");3406  }3407};3408 3409// src/commands/CreateConfigurationCommand.ts3410 3411 3412 3413var CreateConfigurationCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {3414  return [3415    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),3416    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())3417  ];3418}).s("Kafka", "CreateConfiguration", {}).n("KafkaClient", "CreateConfigurationCommand").f(void 0, void 0).ser(se_CreateConfigurationCommand).de(de_CreateConfigurationCommand).build() {3419  static {3420    __name(this, "CreateConfigurationCommand");3421  }3422};3423 3424// src/commands/CreateReplicatorCommand.ts3425 3426 3427 3428var CreateReplicatorCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {3429  return [3430    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),3431    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())3432  ];3433}).s("Kafka", "CreateReplicator", {}).n("KafkaClient", "CreateReplicatorCommand").f(void 0, void 0).ser(se_CreateReplicatorCommand).de(de_CreateReplicatorCommand).build() {3434  static {3435    __name(this, "CreateReplicatorCommand");3436  }3437};3438 3439// src/commands/CreateVpcConnectionCommand.ts3440 3441 3442 3443var CreateVpcConnectionCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {3444  return [3445    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),3446    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())3447  ];3448}).s("Kafka", "CreateVpcConnection", {}).n("KafkaClient", "CreateVpcConnectionCommand").f(void 0, void 0).ser(se_CreateVpcConnectionCommand).de(de_CreateVpcConnectionCommand).build() {3449  static {3450    __name(this, "CreateVpcConnectionCommand");3451  }3452};3453 3454// src/commands/DeleteClusterCommand.ts3455 3456 3457 3458var DeleteClusterCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {3459  return [3460    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),3461    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())3462  ];3463}).s("Kafka", "DeleteCluster", {}).n("KafkaClient", "DeleteClusterCommand").f(void 0, void 0).ser(se_DeleteClusterCommand).de(de_DeleteClusterCommand).build() {3464  static {3465    __name(this, "DeleteClusterCommand");3466  }3467};3468 3469// src/commands/DeleteClusterPolicyCommand.ts3470 3471 3472 3473var DeleteClusterPolicyCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {3474  return [3475    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),3476    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())3477  ];3478}).s("Kafka", "DeleteClusterPolicy", {}).n("KafkaClient", "DeleteClusterPolicyCommand").f(void 0, void 0).ser(se_DeleteClusterPolicyCommand).de(de_DeleteClusterPolicyCommand).build() {3479  static {3480    __name(this, "DeleteClusterPolicyCommand");3481  }3482};3483 3484// src/commands/DeleteConfigurationCommand.ts3485 3486 3487 3488var DeleteConfigurationCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {3489  return [3490    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),3491    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())3492  ];3493}).s("Kafka", "DeleteConfiguration", {}).n("KafkaClient", "DeleteConfigurationCommand").f(void 0, void 0).ser(se_DeleteConfigurationCommand).de(de_DeleteConfigurationCommand).build() {3494  static {3495    __name(this, "DeleteConfigurationCommand");3496  }3497};3498 3499// src/commands/DeleteReplicatorCommand.ts3500 3501 3502 3503var DeleteReplicatorCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {3504  return [3505    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),3506    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())3507  ];3508}).s("Kafka", "DeleteReplicator", {}).n("KafkaClient", "DeleteReplicatorCommand").f(void 0, void 0).ser(se_DeleteReplicatorCommand).de(de_DeleteReplicatorCommand).build() {3509  static {3510    __name(this, "DeleteReplicatorCommand");3511  }3512};3513 3514// src/commands/DeleteVpcConnectionCommand.ts3515 3516 3517 3518var DeleteVpcConnectionCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {3519  return [3520    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),3521    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())3522  ];3523}).s("Kafka", "DeleteVpcConnection", {}).n("KafkaClient", "DeleteVpcConnectionCommand").f(void 0, void 0).ser(se_DeleteVpcConnectionCommand).de(de_DeleteVpcConnectionCommand).build() {3524  static {3525    __name(this, "DeleteVpcConnectionCommand");3526  }3527};3528 3529// src/commands/DescribeClusterCommand.ts3530 3531 3532 3533var DescribeClusterCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {3534  return [3535    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),3536    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())3537  ];3538}).s("Kafka", "DescribeCluster", {}).n("KafkaClient", "DescribeClusterCommand").f(void 0, void 0).ser(se_DescribeClusterCommand).de(de_DescribeClusterCommand).build() {3539  static {3540    __name(this, "DescribeClusterCommand");3541  }3542};3543 3544// src/commands/DescribeClusterOperationCommand.ts3545 3546 3547 3548var DescribeClusterOperationCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {3549  return [3550    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),3551    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())3552  ];3553}).s("Kafka", "DescribeClusterOperation", {}).n("KafkaClient", "DescribeClusterOperationCommand").f(void 0, void 0).ser(se_DescribeClusterOperationCommand).de(de_DescribeClusterOperationCommand).build() {3554  static {3555    __name(this, "DescribeClusterOperationCommand");3556  }3557};3558 3559// src/commands/DescribeClusterOperationV2Command.ts3560 3561 3562 3563var DescribeClusterOperationV2Command = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {3564  return [3565    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),3566    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())3567  ];3568}).s("Kafka", "DescribeClusterOperationV2", {}).n("KafkaClient", "DescribeClusterOperationV2Command").f(void 0, void 0).ser(se_DescribeClusterOperationV2Command).de(de_DescribeClusterOperationV2Command).build() {3569  static {3570    __name(this, "DescribeClusterOperationV2Command");3571  }3572};3573 3574// src/commands/DescribeClusterV2Command.ts3575 3576 3577 3578var DescribeClusterV2Command = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {3579  return [3580    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),3581    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())3582  ];3583}).s("Kafka", "DescribeClusterV2", {}).n("KafkaClient", "DescribeClusterV2Command").f(void 0, void 0).ser(se_DescribeClusterV2Command).de(de_DescribeClusterV2Command).build() {3584  static {3585    __name(this, "DescribeClusterV2Command");3586  }3587};3588 3589// src/commands/DescribeConfigurationCommand.ts3590 3591 3592 3593var DescribeConfigurationCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {3594  return [3595    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),3596    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())3597  ];3598}).s("Kafka", "DescribeConfiguration", {}).n("KafkaClient", "DescribeConfigurationCommand").f(void 0, void 0).ser(se_DescribeConfigurationCommand).de(de_DescribeConfigurationCommand).build() {3599  static {3600    __name(this, "DescribeConfigurationCommand");3601  }3602};3603 3604// src/commands/DescribeConfigurationRevisionCommand.ts3605 3606 3607 3608var DescribeConfigurationRevisionCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {3609  return [3610    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),3611    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())3612  ];3613}).s("Kafka", "DescribeConfigurationRevision", {}).n("KafkaClient", "DescribeConfigurationRevisionCommand").f(void 0, void 0).ser(se_DescribeConfigurationRevisionCommand).de(de_DescribeConfigurationRevisionCommand).build() {3614  static {3615    __name(this, "DescribeConfigurationRevisionCommand");3616  }3617};3618 3619// src/commands/DescribeReplicatorCommand.ts3620 3621 3622 3623var DescribeReplicatorCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {3624  return [3625    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),3626    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())3627  ];3628}).s("Kafka", "DescribeReplicator", {}).n("KafkaClient", "DescribeReplicatorCommand").f(void 0, void 0).ser(se_DescribeReplicatorCommand).de(de_DescribeReplicatorCommand).build() {3629  static {3630    __name(this, "DescribeReplicatorCommand");3631  }3632};3633 3634// src/commands/DescribeVpcConnectionCommand.ts3635 3636 3637 3638var DescribeVpcConnectionCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {3639  return [3640    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),3641    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())3642  ];3643}).s("Kafka", "DescribeVpcConnection", {}).n("KafkaClient", "DescribeVpcConnectionCommand").f(void 0, void 0).ser(se_DescribeVpcConnectionCommand).de(de_DescribeVpcConnectionCommand).build() {3644  static {3645    __name(this, "DescribeVpcConnectionCommand");3646  }3647};3648 3649// src/commands/GetBootstrapBrokersCommand.ts3650 3651 3652 3653var GetBootstrapBrokersCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {3654  return [3655    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),3656    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())3657  ];3658}).s("Kafka", "GetBootstrapBrokers", {}).n("KafkaClient", "GetBootstrapBrokersCommand").f(void 0, void 0).ser(se_GetBootstrapBrokersCommand).de(de_GetBootstrapBrokersCommand).build() {3659  static {3660    __name(this, "GetBootstrapBrokersCommand");3661  }3662};3663 3664// src/commands/GetClusterPolicyCommand.ts3665 3666 3667 3668var GetClusterPolicyCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {3669  return [3670    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),3671    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())3672  ];3673}).s("Kafka", "GetClusterPolicy", {}).n("KafkaClient", "GetClusterPolicyCommand").f(void 0, void 0).ser(se_GetClusterPolicyCommand).de(de_GetClusterPolicyCommand).build() {3674  static {3675    __name(this, "GetClusterPolicyCommand");3676  }3677};3678 3679// src/commands/GetCompatibleKafkaVersionsCommand.ts3680 3681 3682 3683var GetCompatibleKafkaVersionsCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {3684  return [3685    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),3686    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())3687  ];3688}).s("Kafka", "GetCompatibleKafkaVersions", {}).n("KafkaClient", "GetCompatibleKafkaVersionsCommand").f(void 0, void 0).ser(se_GetCompatibleKafkaVersionsCommand).de(de_GetCompatibleKafkaVersionsCommand).build() {3689  static {3690    __name(this, "GetCompatibleKafkaVersionsCommand");3691  }3692};3693 3694// src/commands/ListClientVpcConnectionsCommand.ts3695 3696 3697 3698var ListClientVpcConnectionsCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {3699  return [3700    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),3701    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())3702  ];3703}).s("Kafka", "ListClientVpcConnections", {}).n("KafkaClient", "ListClientVpcConnectionsCommand").f(void 0, void 0).ser(se_ListClientVpcConnectionsCommand).de(de_ListClientVpcConnectionsCommand).build() {3704  static {3705    __name(this, "ListClientVpcConnectionsCommand");3706  }3707};3708 3709// src/commands/ListClusterOperationsCommand.ts3710 3711 3712 3713var ListClusterOperationsCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {3714  return [3715    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),3716    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())3717  ];3718}).s("Kafka", "ListClusterOperations", {}).n("KafkaClient", "ListClusterOperationsCommand").f(void 0, void 0).ser(se_ListClusterOperationsCommand).de(de_ListClusterOperationsCommand).build() {3719  static {3720    __name(this, "ListClusterOperationsCommand");3721  }3722};3723 3724// src/commands/ListClusterOperationsV2Command.ts3725 3726 3727 3728var ListClusterOperationsV2Command = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {3729  return [3730    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),3731    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())3732  ];3733}).s("Kafka", "ListClusterOperationsV2", {}).n("KafkaClient", "ListClusterOperationsV2Command").f(void 0, void 0).ser(se_ListClusterOperationsV2Command).de(de_ListClusterOperationsV2Command).build() {3734  static {3735    __name(this, "ListClusterOperationsV2Command");3736  }3737};3738 3739// src/commands/ListClustersCommand.ts3740 3741 3742 3743var ListClustersCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {3744  return [3745    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),3746    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())3747  ];3748}).s("Kafka", "ListClusters", {}).n("KafkaClient", "ListClustersCommand").f(void 0, void 0).ser(se_ListClustersCommand).de(de_ListClustersCommand).build() {3749  static {3750    __name(this, "ListClustersCommand");3751  }3752};3753 3754// src/commands/ListClustersV2Command.ts3755 3756 3757 3758var ListClustersV2Command = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {3759  return [3760    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),3761    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())3762  ];3763}).s("Kafka", "ListClustersV2", {}).n("KafkaClient", "ListClustersV2Command").f(void 0, void 0).ser(se_ListClustersV2Command).de(de_ListClustersV2Command).build() {3764  static {3765    __name(this, "ListClustersV2Command");3766  }3767};3768 3769// src/commands/ListConfigurationRevisionsCommand.ts3770 3771 3772 3773var ListConfigurationRevisionsCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {3774  return [3775    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),3776    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())3777  ];3778}).s("Kafka", "ListConfigurationRevisions", {}).n("KafkaClient", "ListConfigurationRevisionsCommand").f(void 0, void 0).ser(se_ListConfigurationRevisionsCommand).de(de_ListConfigurationRevisionsCommand).build() {3779  static {3780    __name(this, "ListConfigurationRevisionsCommand");3781  }3782};3783 3784// src/commands/ListConfigurationsCommand.ts3785 3786 3787 3788var ListConfigurationsCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {3789  return [3790    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),3791    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())3792  ];3793}).s("Kafka", "ListConfigurations", {}).n("KafkaClient", "ListConfigurationsCommand").f(void 0, void 0).ser(se_ListConfigurationsCommand).de(de_ListConfigurationsCommand).build() {3794  static {3795    __name(this, "ListConfigurationsCommand");3796  }3797};3798 3799// src/commands/ListKafkaVersionsCommand.ts3800 3801 3802 3803var ListKafkaVersionsCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {3804  return [3805    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),3806    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())3807  ];3808}).s("Kafka", "ListKafkaVersions", {}).n("KafkaClient", "ListKafkaVersionsCommand").f(void 0, void 0).ser(se_ListKafkaVersionsCommand).de(de_ListKafkaVersionsCommand).build() {3809  static {3810    __name(this, "ListKafkaVersionsCommand");3811  }3812};3813 3814// src/commands/ListNodesCommand.ts3815 3816 3817 3818var ListNodesCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {3819  return [3820    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),3821    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())3822  ];3823}).s("Kafka", "ListNodes", {}).n("KafkaClient", "ListNodesCommand").f(void 0, void 0).ser(se_ListNodesCommand).de(de_ListNodesCommand).build() {3824  static {3825    __name(this, "ListNodesCommand");3826  }3827};3828 3829// src/commands/ListReplicatorsCommand.ts3830 3831 3832 3833var ListReplicatorsCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {3834  return [3835    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),3836    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())3837  ];3838}).s("Kafka", "ListReplicators", {}).n("KafkaClient", "ListReplicatorsCommand").f(void 0, void 0).ser(se_ListReplicatorsCommand).de(de_ListReplicatorsCommand).build() {3839  static {3840    __name(this, "ListReplicatorsCommand");3841  }3842};3843 3844// src/commands/ListScramSecretsCommand.ts3845 3846 3847 3848var ListScramSecretsCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {3849  return [3850    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),3851    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())3852  ];3853}).s("Kafka", "ListScramSecrets", {}).n("KafkaClient", "ListScramSecretsCommand").f(void 0, void 0).ser(se_ListScramSecretsCommand).de(de_ListScramSecretsCommand).build() {3854  static {3855    __name(this, "ListScramSecretsCommand");3856  }3857};3858 3859// src/commands/ListTagsForResourceCommand.ts3860 3861 3862 3863var ListTagsForResourceCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {3864  return [3865    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),3866    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())3867  ];3868}).s("Kafka", "ListTagsForResource", {}).n("KafkaClient", "ListTagsForResourceCommand").f(void 0, void 0).ser(se_ListTagsForResourceCommand).de(de_ListTagsForResourceCommand).build() {3869  static {3870    __name(this, "ListTagsForResourceCommand");3871  }3872};3873 3874// src/commands/ListVpcConnectionsCommand.ts3875 3876 3877 3878var ListVpcConnectionsCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {3879  return [3880    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),3881    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())3882  ];3883}).s("Kafka", "ListVpcConnections", {}).n("KafkaClient", "ListVpcConnectionsCommand").f(void 0, void 0).ser(se_ListVpcConnectionsCommand).de(de_ListVpcConnectionsCommand).build() {3884  static {3885    __name(this, "ListVpcConnectionsCommand");3886  }3887};3888 3889// src/commands/PutClusterPolicyCommand.ts3890 3891 3892 3893var PutClusterPolicyCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {3894  return [3895    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),3896    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())3897  ];3898}).s("Kafka", "PutClusterPolicy", {}).n("KafkaClient", "PutClusterPolicyCommand").f(void 0, void 0).ser(se_PutClusterPolicyCommand).de(de_PutClusterPolicyCommand).build() {3899  static {3900    __name(this, "PutClusterPolicyCommand");3901  }3902};3903 3904// src/commands/RebootBrokerCommand.ts3905 3906 3907 3908var RebootBrokerCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {3909  return [3910    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),3911    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())3912  ];3913}).s("Kafka", "RebootBroker", {}).n("KafkaClient", "RebootBrokerCommand").f(void 0, void 0).ser(se_RebootBrokerCommand).de(de_RebootBrokerCommand).build() {3914  static {3915    __name(this, "RebootBrokerCommand");3916  }3917};3918 3919// src/commands/RejectClientVpcConnectionCommand.ts3920 3921 3922 3923var RejectClientVpcConnectionCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {3924  return [3925    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),3926    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())3927  ];3928}).s("Kafka", "RejectClientVpcConnection", {}).n("KafkaClient", "RejectClientVpcConnectionCommand").f(void 0, void 0).ser(se_RejectClientVpcConnectionCommand).de(de_RejectClientVpcConnectionCommand).build() {3929  static {3930    __name(this, "RejectClientVpcConnectionCommand");3931  }3932};3933 3934// src/commands/TagResourceCommand.ts3935 3936 3937 3938var TagResourceCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {3939  return [3940    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),3941    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())3942  ];3943}).s("Kafka", "TagResource", {}).n("KafkaClient", "TagResourceCommand").f(void 0, void 0).ser(se_TagResourceCommand).de(de_TagResourceCommand).build() {3944  static {3945    __name(this, "TagResourceCommand");3946  }3947};3948 3949// src/commands/UntagResourceCommand.ts3950 3951 3952 3953var UntagResourceCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {3954  return [3955    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),3956    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())3957  ];3958}).s("Kafka", "UntagResource", {}).n("KafkaClient", "UntagResourceCommand").f(void 0, void 0).ser(se_UntagResourceCommand).de(de_UntagResourceCommand).build() {3959  static {3960    __name(this, "UntagResourceCommand");3961  }3962};3963 3964// src/commands/UpdateBrokerCountCommand.ts3965 3966 3967 3968var UpdateBrokerCountCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {3969  return [3970    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),3971    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())3972  ];3973}).s("Kafka", "UpdateBrokerCount", {}).n("KafkaClient", "UpdateBrokerCountCommand").f(void 0, void 0).ser(se_UpdateBrokerCountCommand).de(de_UpdateBrokerCountCommand).build() {3974  static {3975    __name(this, "UpdateBrokerCountCommand");3976  }3977};3978 3979// src/commands/UpdateBrokerStorageCommand.ts3980 3981 3982 3983var UpdateBrokerStorageCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {3984  return [3985    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),3986    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())3987  ];3988}).s("Kafka", "UpdateBrokerStorage", {}).n("KafkaClient", "UpdateBrokerStorageCommand").f(void 0, void 0).ser(se_UpdateBrokerStorageCommand).de(de_UpdateBrokerStorageCommand).build() {3989  static {3990    __name(this, "UpdateBrokerStorageCommand");3991  }3992};3993 3994// src/commands/UpdateBrokerTypeCommand.ts3995 3996 3997 3998var UpdateBrokerTypeCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {3999  return [4000    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),4001    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())4002  ];4003}).s("Kafka", "UpdateBrokerType", {}).n("KafkaClient", "UpdateBrokerTypeCommand").f(void 0, void 0).ser(se_UpdateBrokerTypeCommand).de(de_UpdateBrokerTypeCommand).build() {4004  static {4005    __name(this, "UpdateBrokerTypeCommand");4006  }4007};4008 4009// src/commands/UpdateClusterConfigurationCommand.ts4010 4011 4012 4013var UpdateClusterConfigurationCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {4014  return [4015    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),4016    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())4017  ];4018}).s("Kafka", "UpdateClusterConfiguration", {}).n("KafkaClient", "UpdateClusterConfigurationCommand").f(void 0, void 0).ser(se_UpdateClusterConfigurationCommand).de(de_UpdateClusterConfigurationCommand).build() {4019  static {4020    __name(this, "UpdateClusterConfigurationCommand");4021  }4022};4023 4024// src/commands/UpdateClusterKafkaVersionCommand.ts4025 4026 4027 4028var UpdateClusterKafkaVersionCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {4029  return [4030    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),4031    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())4032  ];4033}).s("Kafka", "UpdateClusterKafkaVersion", {}).n("KafkaClient", "UpdateClusterKafkaVersionCommand").f(void 0, void 0).ser(se_UpdateClusterKafkaVersionCommand).de(de_UpdateClusterKafkaVersionCommand).build() {4034  static {4035    __name(this, "UpdateClusterKafkaVersionCommand");4036  }4037};4038 4039// src/commands/UpdateConfigurationCommand.ts4040 4041 4042 4043var UpdateConfigurationCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {4044  return [4045    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),4046    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())4047  ];4048}).s("Kafka", "UpdateConfiguration", {}).n("KafkaClient", "UpdateConfigurationCommand").f(void 0, void 0).ser(se_UpdateConfigurationCommand).de(de_UpdateConfigurationCommand).build() {4049  static {4050    __name(this, "UpdateConfigurationCommand");4051  }4052};4053 4054// src/commands/UpdateConnectivityCommand.ts4055 4056 4057 4058var UpdateConnectivityCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {4059  return [4060    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),4061    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())4062  ];4063}).s("Kafka", "UpdateConnectivity", {}).n("KafkaClient", "UpdateConnectivityCommand").f(void 0, void 0).ser(se_UpdateConnectivityCommand).de(de_UpdateConnectivityCommand).build() {4064  static {4065    __name(this, "UpdateConnectivityCommand");4066  }4067};4068 4069// src/commands/UpdateMonitoringCommand.ts4070 4071 4072 4073var UpdateMonitoringCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {4074  return [4075    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),4076    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())4077  ];4078}).s("Kafka", "UpdateMonitoring", {}).n("KafkaClient", "UpdateMonitoringCommand").f(void 0, void 0).ser(se_UpdateMonitoringCommand).de(de_UpdateMonitoringCommand).build() {4079  static {4080    __name(this, "UpdateMonitoringCommand");4081  }4082};4083 4084// src/commands/UpdateReplicationInfoCommand.ts4085 4086 4087 4088var UpdateReplicationInfoCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {4089  return [4090    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),4091    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())4092  ];4093}).s("Kafka", "UpdateReplicationInfo", {}).n("KafkaClient", "UpdateReplicationInfoCommand").f(void 0, void 0).ser(se_UpdateReplicationInfoCommand).de(de_UpdateReplicationInfoCommand).build() {4094  static {4095    __name(this, "UpdateReplicationInfoCommand");4096  }4097};4098 4099// src/commands/UpdateSecurityCommand.ts4100 4101 4102 4103var UpdateSecurityCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {4104  return [4105    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),4106    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())4107  ];4108}).s("Kafka", "UpdateSecurity", {}).n("KafkaClient", "UpdateSecurityCommand").f(void 0, void 0).ser(se_UpdateSecurityCommand).de(de_UpdateSecurityCommand).build() {4109  static {4110    __name(this, "UpdateSecurityCommand");4111  }4112};4113 4114// src/commands/UpdateStorageCommand.ts4115 4116 4117 4118var UpdateStorageCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {4119  return [4120    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),4121    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())4122  ];4123}).s("Kafka", "UpdateStorage", {}).n("KafkaClient", "UpdateStorageCommand").f(void 0, void 0).ser(se_UpdateStorageCommand).de(de_UpdateStorageCommand).build() {4124  static {4125    __name(this, "UpdateStorageCommand");4126  }4127};4128 4129// src/Kafka.ts4130var commands = {4131  BatchAssociateScramSecretCommand,4132  BatchDisassociateScramSecretCommand,4133  CreateClusterCommand,4134  CreateClusterV2Command,4135  CreateConfigurationCommand,4136  CreateReplicatorCommand,4137  CreateVpcConnectionCommand,4138  DeleteClusterCommand,4139  DeleteClusterPolicyCommand,4140  DeleteConfigurationCommand,4141  DeleteReplicatorCommand,4142  DeleteVpcConnectionCommand,4143  DescribeClusterCommand,4144  DescribeClusterOperationCommand,4145  DescribeClusterOperationV2Command,4146  DescribeClusterV2Command,4147  DescribeConfigurationCommand,4148  DescribeConfigurationRevisionCommand,4149  DescribeReplicatorCommand,4150  DescribeVpcConnectionCommand,4151  GetBootstrapBrokersCommand,4152  GetClusterPolicyCommand,4153  GetCompatibleKafkaVersionsCommand,4154  ListClientVpcConnectionsCommand,4155  ListClusterOperationsCommand,4156  ListClusterOperationsV2Command,4157  ListClustersCommand,4158  ListClustersV2Command,4159  ListConfigurationRevisionsCommand,4160  ListConfigurationsCommand,4161  ListKafkaVersionsCommand,4162  ListNodesCommand,4163  ListReplicatorsCommand,4164  ListScramSecretsCommand,4165  ListTagsForResourceCommand,4166  ListVpcConnectionsCommand,4167  PutClusterPolicyCommand,4168  RebootBrokerCommand,4169  RejectClientVpcConnectionCommand,4170  TagResourceCommand,4171  UntagResourceCommand,4172  UpdateBrokerCountCommand,4173  UpdateBrokerStorageCommand,4174  UpdateBrokerTypeCommand,4175  UpdateClusterConfigurationCommand,4176  UpdateClusterKafkaVersionCommand,4177  UpdateConfigurationCommand,4178  UpdateConnectivityCommand,4179  UpdateMonitoringCommand,4180  UpdateReplicationInfoCommand,4181  UpdateSecurityCommand,4182  UpdateStorageCommand4183};4184var Kafka = class extends KafkaClient {4185  static {4186    __name(this, "Kafka");4187  }4188};4189(0, import_smithy_client.createAggregatedClient)(commands, Kafka);4190 4191// src/pagination/ListClientVpcConnectionsPaginator.ts4192 4193var paginateListClientVpcConnections = (0, import_core.createPaginator)(KafkaClient, ListClientVpcConnectionsCommand, "NextToken", "NextToken", "MaxResults");4194 4195// src/pagination/ListClusterOperationsPaginator.ts4196 4197var paginateListClusterOperations = (0, import_core.createPaginator)(KafkaClient, ListClusterOperationsCommand, "NextToken", "NextToken", "MaxResults");4198 4199// src/pagination/ListClusterOperationsV2Paginator.ts4200 4201var paginateListClusterOperationsV2 = (0, import_core.createPaginator)(KafkaClient, ListClusterOperationsV2Command, "NextToken", "NextToken", "MaxResults");4202 4203// src/pagination/ListClustersPaginator.ts4204 4205var paginateListClusters = (0, import_core.createPaginator)(KafkaClient, ListClustersCommand, "NextToken", "NextToken", "MaxResults");4206 4207// src/pagination/ListClustersV2Paginator.ts4208 4209var paginateListClustersV2 = (0, import_core.createPaginator)(KafkaClient, ListClustersV2Command, "NextToken", "NextToken", "MaxResults");4210 4211// src/pagination/ListConfigurationRevisionsPaginator.ts4212 4213var paginateListConfigurationRevisions = (0, import_core.createPaginator)(KafkaClient, ListConfigurationRevisionsCommand, "NextToken", "NextToken", "MaxResults");4214 4215// src/pagination/ListConfigurationsPaginator.ts4216 4217var paginateListConfigurations = (0, import_core.createPaginator)(KafkaClient, ListConfigurationsCommand, "NextToken", "NextToken", "MaxResults");4218 4219// src/pagination/ListKafkaVersionsPaginator.ts4220 4221var paginateListKafkaVersions = (0, import_core.createPaginator)(KafkaClient, ListKafkaVersionsCommand, "NextToken", "NextToken", "MaxResults");4222 4223// src/pagination/ListNodesPaginator.ts4224 4225var paginateListNodes = (0, import_core.createPaginator)(KafkaClient, ListNodesCommand, "NextToken", "NextToken", "MaxResults");4226 4227// src/pagination/ListReplicatorsPaginator.ts4228 4229var paginateListReplicators = (0, import_core.createPaginator)(KafkaClient, ListReplicatorsCommand, "NextToken", "NextToken", "MaxResults");4230 4231// src/pagination/ListScramSecretsPaginator.ts4232 4233var paginateListScramSecrets = (0, import_core.createPaginator)(KafkaClient, ListScramSecretsCommand, "NextToken", "NextToken", "MaxResults");4234 4235// src/pagination/ListVpcConnectionsPaginator.ts4236 4237var paginateListVpcConnections = (0, import_core.createPaginator)(KafkaClient, ListVpcConnectionsCommand, "NextToken", "NextToken", "MaxResults");4238// Annotate the CommonJS export names for ESM import in node:4239 42400 && (module.exports = {4241  KafkaServiceException,4242  __Client,4243  KafkaClient,4244  Kafka,4245  $Command,4246  BatchAssociateScramSecretCommand,4247  BatchDisassociateScramSecretCommand,4248  CreateClusterCommand,4249  CreateClusterV2Command,4250  CreateConfigurationCommand,4251  CreateReplicatorCommand,4252  CreateVpcConnectionCommand,4253  DeleteClusterCommand,4254  DeleteClusterPolicyCommand,4255  DeleteConfigurationCommand,4256  DeleteReplicatorCommand,4257  DeleteVpcConnectionCommand,4258  DescribeClusterCommand,4259  DescribeClusterOperationCommand,4260  DescribeClusterOperationV2Command,4261  DescribeClusterV2Command,4262  DescribeConfigurationCommand,4263  DescribeConfigurationRevisionCommand,4264  DescribeReplicatorCommand,4265  DescribeVpcConnectionCommand,4266  GetBootstrapBrokersCommand,4267  GetClusterPolicyCommand,4268  GetCompatibleKafkaVersionsCommand,4269  ListClientVpcConnectionsCommand,4270  ListClusterOperationsCommand,4271  ListClusterOperationsV2Command,4272  ListClustersCommand,4273  ListClustersV2Command,4274  ListConfigurationRevisionsCommand,4275  ListConfigurationsCommand,4276  ListKafkaVersionsCommand,4277  ListNodesCommand,4278  ListReplicatorsCommand,4279  ListScramSecretsCommand,4280  ListTagsForResourceCommand,4281  ListVpcConnectionsCommand,4282  PutClusterPolicyCommand,4283  RebootBrokerCommand,4284  RejectClientVpcConnectionCommand,4285  TagResourceCommand,4286  UntagResourceCommand,4287  UpdateBrokerCountCommand,4288  UpdateBrokerStorageCommand,4289  UpdateBrokerTypeCommand,4290  UpdateClusterConfigurationCommand,4291  UpdateClusterKafkaVersionCommand,4292  UpdateConfigurationCommand,4293  UpdateConnectivityCommand,4294  UpdateMonitoringCommand,4295  UpdateReplicationInfoCommand,4296  UpdateSecurityCommand,4297  UpdateStorageCommand,4298  paginateListClientVpcConnections,4299  paginateListClusterOperations,4300  paginateListClusterOperationsV2,4301  paginateListClusters,4302  paginateListClustersV2,4303  paginateListConfigurationRevisions,4304  paginateListConfigurations,4305  paginateListKafkaVersions,4306  paginateListNodes,4307  paginateListReplicators,4308  paginateListScramSecrets,4309  paginateListVpcConnections,4310  VpcConnectionState,4311  ClusterType,4312  BrokerAZDistribution,4313  CustomerActionStatus,4314  ClientBroker,4315  EnhancedMonitoring,4316  StorageMode,4317  ClusterState,4318  UserIdentityType,4319  ConfigurationState,4320  KafkaVersionStatus,4321  NodeType,4322  TargetCompressionType,4323  ReplicationStartingPositionType,4324  ReplicationTopicNameConfigurationType,4325  ReplicatorState,4326  BadRequestException,4327  ForbiddenException,4328  InternalServerErrorException,4329  NotFoundException,4330  ServiceUnavailableException,4331  TooManyRequestsException,4332  UnauthorizedException,4333  ConflictException4334});4335 4336