File Explorer

/var/runtime/node_modules/@aws-sdk/client-kafkaconnect/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.js71.4 KB · 1647 lines
"use strict";var __defProp = Object.defineProperty;var __getOwnPropDesc = Object.getOwnPropertyDescriptor;var __getOwnPropNames = Object.getOwnPropertyNames;var __hasOwnProp = Object.prototype.hasOwnProperty;var __name = (target, value) => __defProp(target, "name", { value, configurable: true });var __export = (target, all) => {  for (var name in all)    __defProp(target, name, { get: all[name], enumerable: true });};var __copyProps = (to, from, except, desc) => {  if (from && typeof from === "object" || typeof from === "function") {    for (let key of __getOwnPropNames(from))      if (!__hasOwnProp.call(to, key) && key !== except)        __defProp(to, key, { get: () => from[key], enumerable: !(desc = __getOwnPropDesc(from, key)) || desc.enumerable });  }  return to;};var __toCommonJS = (mod) => __copyProps(__defProp({}, "__esModule", { value: true }), mod); // src/index.tsvar index_exports = {};__export(index_exports, {  BadRequestException: () => BadRequestException,  ConflictException: () => ConflictException,  ConnectorOperationState: () => ConnectorOperationState,  ConnectorOperationStepState: () => ConnectorOperationStepState,  ConnectorOperationStepType: () => ConnectorOperationStepType,  ConnectorOperationType: () => ConnectorOperationType,  ConnectorState: () => ConnectorState,  CreateConnectorCommand: () => CreateConnectorCommand,  CreateConnectorRequestFilterSensitiveLog: () => CreateConnectorRequestFilterSensitiveLog,  CreateCustomPluginCommand: () => CreateCustomPluginCommand,  CreateWorkerConfigurationCommand: () => CreateWorkerConfigurationCommand,  CreateWorkerConfigurationRequestFilterSensitiveLog: () => CreateWorkerConfigurationRequestFilterSensitiveLog,  CustomPluginContentType: () => CustomPluginContentType,  CustomPluginState: () => CustomPluginState,  DeleteConnectorCommand: () => DeleteConnectorCommand,  DeleteCustomPluginCommand: () => DeleteCustomPluginCommand,  DeleteWorkerConfigurationCommand: () => DeleteWorkerConfigurationCommand,  DescribeConnectorCommand: () => DescribeConnectorCommand,  DescribeConnectorOperationCommand: () => DescribeConnectorOperationCommand,  DescribeConnectorOperationResponseFilterSensitiveLog: () => DescribeConnectorOperationResponseFilterSensitiveLog,  DescribeConnectorResponseFilterSensitiveLog: () => DescribeConnectorResponseFilterSensitiveLog,  DescribeCustomPluginCommand: () => DescribeCustomPluginCommand,  DescribeWorkerConfigurationCommand: () => DescribeWorkerConfigurationCommand,  DescribeWorkerConfigurationResponseFilterSensitiveLog: () => DescribeWorkerConfigurationResponseFilterSensitiveLog,  ForbiddenException: () => ForbiddenException,  InternalServerErrorException: () => InternalServerErrorException,  KafkaClusterClientAuthenticationType: () => KafkaClusterClientAuthenticationType,  KafkaClusterEncryptionInTransitType: () => KafkaClusterEncryptionInTransitType,  KafkaConnect: () => KafkaConnect,  KafkaConnectClient: () => KafkaConnectClient,  KafkaConnectServiceException: () => KafkaConnectServiceException,  ListConnectorOperationsCommand: () => ListConnectorOperationsCommand,  ListConnectorsCommand: () => ListConnectorsCommand,  ListCustomPluginsCommand: () => ListCustomPluginsCommand,  ListTagsForResourceCommand: () => ListTagsForResourceCommand,  ListWorkerConfigurationsCommand: () => ListWorkerConfigurationsCommand,  NotFoundException: () => NotFoundException,  ServiceUnavailableException: () => ServiceUnavailableException,  TagResourceCommand: () => TagResourceCommand,  TooManyRequestsException: () => TooManyRequestsException,  UnauthorizedException: () => UnauthorizedException,  UntagResourceCommand: () => UntagResourceCommand,  UpdateConnectorCommand: () => UpdateConnectorCommand,  UpdateConnectorRequestFilterSensitiveLog: () => UpdateConnectorRequestFilterSensitiveLog,  WorkerConfigurationRevisionDescriptionFilterSensitiveLog: () => WorkerConfigurationRevisionDescriptionFilterSensitiveLog,  WorkerConfigurationState: () => WorkerConfigurationState,  __Client: () => import_smithy_client.Client,  paginateListConnectorOperations: () => paginateListConnectorOperations,  paginateListConnectors: () => paginateListConnectors,  paginateListCustomPlugins: () => paginateListCustomPlugins,  paginateListWorkerConfigurations: () => paginateListWorkerConfigurations});module.exports = __toCommonJS(index_exports); // src/KafkaConnectClient.tsvar import_middleware_host_header = require("@aws-sdk/middleware-host-header");var import_middleware_logger = require("@aws-sdk/middleware-logger");var import_middleware_recursion_detection = require("@aws-sdk/middleware-recursion-detection");var import_middleware_user_agent = require("@aws-sdk/middleware-user-agent");var import_config_resolver = require("@smithy/config-resolver");var import_core = require("@smithy/core");var import_middleware_content_length = require("@smithy/middleware-content-length");var import_middleware_endpoint = require("@smithy/middleware-endpoint");var import_middleware_retry = require("@smithy/middleware-retry"); var import_httpAuthSchemeProvider = require("./auth/httpAuthSchemeProvider"); // src/endpoint/EndpointParameters.tsvar resolveClientEndpointParameters = /* @__PURE__ */ __name((options) => {  return Object.assign(options, {    useDualstackEndpoint: options.useDualstackEndpoint ?? false,    useFipsEndpoint: options.useFipsEndpoint ?? false,    defaultSigningName: "kafkaconnect"  });}, "resolveClientEndpointParameters");var commonParams = {  UseFIPS: { type: "builtInParams", name: "useFipsEndpoint" },  Endpoint: { type: "builtInParams", name: "endpoint" },  Region: { type: "builtInParams", name: "region" },  UseDualStack: { type: "builtInParams", name: "useDualstackEndpoint" }}; // src/KafkaConnectClient.tsvar import_runtimeConfig = require("././runtimeConfig"); // src/runtimeExtensions.tsvar import_region_config_resolver = require("@aws-sdk/region-config-resolver");var import_protocol_http = require("@smithy/protocol-http");var import_smithy_client = require("@smithy/smithy-client"); // src/auth/httpAuthExtensionConfiguration.tsvar getHttpAuthExtensionConfiguration = /* @__PURE__ */ __name((runtimeConfig) => {  const _httpAuthSchemes = runtimeConfig.httpAuthSchemes;  let _httpAuthSchemeProvider = runtimeConfig.httpAuthSchemeProvider;  let _credentials = runtimeConfig.credentials;  return {    setHttpAuthScheme(httpAuthScheme) {      const index = _httpAuthSchemes.findIndex((scheme) => scheme.schemeId === httpAuthScheme.schemeId);      if (index === -1) {        _httpAuthSchemes.push(httpAuthScheme);      } else {        _httpAuthSchemes.splice(index, 1, httpAuthScheme);      }    },    httpAuthSchemes() {      return _httpAuthSchemes;    },    setHttpAuthSchemeProvider(httpAuthSchemeProvider) {      _httpAuthSchemeProvider = httpAuthSchemeProvider;    },    httpAuthSchemeProvider() {      return _httpAuthSchemeProvider;    },    setCredentials(credentials) {      _credentials = credentials;    },    credentials() {      return _credentials;    }  };}, "getHttpAuthExtensionConfiguration");var resolveHttpAuthRuntimeConfig = /* @__PURE__ */ __name((config) => {  return {    httpAuthSchemes: config.httpAuthSchemes(),    httpAuthSchemeProvider: config.httpAuthSchemeProvider(),    credentials: config.credentials()  };}, "resolveHttpAuthRuntimeConfig"); // src/runtimeExtensions.tsvar resolveRuntimeExtensions = /* @__PURE__ */ __name((runtimeConfig, extensions) => {  const extensionConfiguration = Object.assign(    (0, import_region_config_resolver.getAwsRegionExtensionConfiguration)(runtimeConfig),    (0, import_smithy_client.getDefaultExtensionConfiguration)(runtimeConfig),    (0, import_protocol_http.getHttpHandlerExtensionConfiguration)(runtimeConfig),    getHttpAuthExtensionConfiguration(runtimeConfig)  );  extensions.forEach((extension) => extension.configure(extensionConfiguration));  return Object.assign(    runtimeConfig,    (0, import_region_config_resolver.resolveAwsRegionExtensionConfiguration)(extensionConfiguration),    (0, import_smithy_client.resolveDefaultRuntimeConfig)(extensionConfiguration),    (0, import_protocol_http.resolveHttpHandlerRuntimeConfig)(extensionConfiguration),    resolveHttpAuthRuntimeConfig(extensionConfiguration)  );}, "resolveRuntimeExtensions"); // src/KafkaConnectClient.tsvar KafkaConnectClient = class extends import_smithy_client.Client {  static {    __name(this, "KafkaConnectClient");  }  /**   * The resolved configuration of KafkaConnectClient class. This is resolved and normalized from the {@link KafkaConnectClientConfig | constructor configuration interface}.   */  config;  constructor(...[configuration]) {    const _config_0 = (0, import_runtimeConfig.getRuntimeConfig)(configuration || {});    super(_config_0);    this.initConfig = _config_0;    const _config_1 = resolveClientEndpointParameters(_config_0);    const _config_2 = (0, import_middleware_user_agent.resolveUserAgentConfig)(_config_1);    const _config_3 = (0, import_middleware_retry.resolveRetryConfig)(_config_2);    const _config_4 = (0, import_config_resolver.resolveRegionConfig)(_config_3);    const _config_5 = (0, import_middleware_host_header.resolveHostHeaderConfig)(_config_4);    const _config_6 = (0, import_middleware_endpoint.resolveEndpointConfig)(_config_5);    const _config_7 = (0, import_httpAuthSchemeProvider.resolveHttpAuthSchemeConfig)(_config_6);    const _config_8 = resolveRuntimeExtensions(_config_7, configuration?.extensions || []);    this.config = _config_8;    this.middlewareStack.use((0, import_middleware_user_agent.getUserAgentPlugin)(this.config));    this.middlewareStack.use((0, import_middleware_retry.getRetryPlugin)(this.config));    this.middlewareStack.use((0, import_middleware_content_length.getContentLengthPlugin)(this.config));    this.middlewareStack.use((0, import_middleware_host_header.getHostHeaderPlugin)(this.config));    this.middlewareStack.use((0, import_middleware_logger.getLoggerPlugin)(this.config));    this.middlewareStack.use((0, import_middleware_recursion_detection.getRecursionDetectionPlugin)(this.config));    this.middlewareStack.use(      (0, import_core.getHttpAuthSchemeEndpointRuleSetPlugin)(this.config, {        httpAuthSchemeParametersProvider: import_httpAuthSchemeProvider.defaultKafkaConnectHttpAuthSchemeParametersProvider,        identityProviderConfigProvider: /* @__PURE__ */ __name(async (config) => new import_core.DefaultIdentityProviderConfig({          "aws.auth#sigv4": config.credentials        }), "identityProviderConfigProvider")      })    );    this.middlewareStack.use((0, import_core.getHttpSigningPlugin)(this.config));  }  /**   * Destroy underlying resources, like sockets. It's usually not necessary to do this.   * However in Node.js, it's best to explicitly shut down the client's agent when it is no longer needed.   * Otherwise, sockets might stay open for quite a long time before the server terminates them.   */  destroy() {    super.destroy();  }}; // src/KafkaConnect.ts  // src/commands/CreateConnectorCommand.ts var import_middleware_serde = require("@smithy/middleware-serde");  // src/models/models_0.ts  // src/models/KafkaConnectServiceException.ts var KafkaConnectServiceException = class _KafkaConnectServiceException extends import_smithy_client.ServiceException {  static {    __name(this, "KafkaConnectServiceException");  }  /**   * @internal   */  constructor(options) {    super(options);    Object.setPrototypeOf(this, _KafkaConnectServiceException.prototype);  }}; // src/models/models_0.tsvar ConnectorOperationStepState = {  CANCELLED: "CANCELLED",  COMPLETED: "COMPLETED",  FAILED: "FAILED",  IN_PROGRESS: "IN_PROGRESS",  PENDING: "PENDING"};var ConnectorOperationStepType = {  FINALIZE_UPDATE: "FINALIZE_UPDATE",  INITIALIZE_UPDATE: "INITIALIZE_UPDATE",  UPDATE_CONNECTOR_CONFIGURATION: "UPDATE_CONNECTOR_CONFIGURATION",  UPDATE_WORKER_SETTING: "UPDATE_WORKER_SETTING",  VALIDATE_UPDATE: "VALIDATE_UPDATE"};var ConnectorOperationState = {  PENDING: "PENDING",  ROLLBACK_COMPLETE: "ROLLBACK_COMPLETE",  ROLLBACK_FAILED: "ROLLBACK_FAILED",  ROLLBACK_IN_PROGRESS: "ROLLBACK_IN_PROGRESS",  UPDATE_COMPLETE: "UPDATE_COMPLETE",  UPDATE_FAILED: "UPDATE_FAILED",  UPDATE_IN_PROGRESS: "UPDATE_IN_PROGRESS"};var ConnectorOperationType = {  ISOLATE_CONNECTOR: "ISOLATE_CONNECTOR",  RESTORE_CONNECTOR: "RESTORE_CONNECTOR",  UPDATE_CONNECTOR_CONFIGURATION: "UPDATE_CONNECTOR_CONFIGURATION",  UPDATE_WORKER_SETTING: "UPDATE_WORKER_SETTING"};var ConnectorState = {  CREATING: "CREATING",  DELETING: "DELETING",  FAILED: "FAILED",  RUNNING: "RUNNING",  UPDATING: "UPDATING"};var KafkaClusterClientAuthenticationType = {  IAM: "IAM",  NONE: "NONE"};var KafkaClusterEncryptionInTransitType = {  PLAINTEXT: "PLAINTEXT",  TLS: "TLS"};var CustomPluginState = {  ACTIVE: "ACTIVE",  CREATE_FAILED: "CREATE_FAILED",  CREATING: "CREATING",  DELETING: "DELETING",  UPDATE_FAILED: "UPDATE_FAILED",  UPDATING: "UPDATING"};var CustomPluginContentType = {  JAR: "JAR",  ZIP: "ZIP"};var WorkerConfigurationState = {  ACTIVE: "ACTIVE",  DELETING: "DELETING"};var BadRequestException = class _BadRequestException extends KafkaConnectServiceException {  static {    __name(this, "BadRequestException");  }  name = "BadRequestException";  $fault = "client";  /**   * @internal   */  constructor(opts) {    super({      name: "BadRequestException",      $fault: "client",      ...opts    });    Object.setPrototypeOf(this, _BadRequestException.prototype);  }};var ConflictException = class _ConflictException extends KafkaConnectServiceException {  static {    __name(this, "ConflictException");  }  name = "ConflictException";  $fault = "client";  /**   * @internal   */  constructor(opts) {    super({      name: "ConflictException",      $fault: "client",      ...opts    });    Object.setPrototypeOf(this, _ConflictException.prototype);  }};var ForbiddenException = class _ForbiddenException extends KafkaConnectServiceException {  static {    __name(this, "ForbiddenException");  }  name = "ForbiddenException";  $fault = "client";  /**   * @internal   */  constructor(opts) {    super({      name: "ForbiddenException",      $fault: "client",      ...opts    });    Object.setPrototypeOf(this, _ForbiddenException.prototype);  }};var InternalServerErrorException = class _InternalServerErrorException extends KafkaConnectServiceException {  static {    __name(this, "InternalServerErrorException");  }  name = "InternalServerErrorException";  $fault = "server";  /**   * @internal   */  constructor(opts) {    super({      name: "InternalServerErrorException",      $fault: "server",      ...opts    });    Object.setPrototypeOf(this, _InternalServerErrorException.prototype);  }};var NotFoundException = class _NotFoundException extends KafkaConnectServiceException {  static {    __name(this, "NotFoundException");  }  name = "NotFoundException";  $fault = "client";  /**   * @internal   */  constructor(opts) {    super({      name: "NotFoundException",      $fault: "client",      ...opts    });    Object.setPrototypeOf(this, _NotFoundException.prototype);  }};var ServiceUnavailableException = class _ServiceUnavailableException extends KafkaConnectServiceException {  static {    __name(this, "ServiceUnavailableException");  }  name = "ServiceUnavailableException";  $fault = "server";  /**   * @internal   */  constructor(opts) {    super({      name: "ServiceUnavailableException",      $fault: "server",      ...opts    });    Object.setPrototypeOf(this, _ServiceUnavailableException.prototype);  }};var TooManyRequestsException = class _TooManyRequestsException extends KafkaConnectServiceException {  static {    __name(this, "TooManyRequestsException");  }  name = "TooManyRequestsException";  $fault = "client";  /**   * @internal   */  constructor(opts) {    super({      name: "TooManyRequestsException",      $fault: "client",      ...opts    });    Object.setPrototypeOf(this, _TooManyRequestsException.prototype);  }};var UnauthorizedException = class _UnauthorizedException extends KafkaConnectServiceException {  static {    __name(this, "UnauthorizedException");  }  name = "UnauthorizedException";  $fault = "client";  /**   * @internal   */  constructor(opts) {    super({      name: "UnauthorizedException",      $fault: "client",      ...opts    });    Object.setPrototypeOf(this, _UnauthorizedException.prototype);  }};var CreateConnectorRequestFilterSensitiveLog = /* @__PURE__ */ __name((obj) => ({  ...obj,  ...obj.connectorConfiguration && { connectorConfiguration: import_smithy_client.SENSITIVE_STRING }}), "CreateConnectorRequestFilterSensitiveLog");var CreateWorkerConfigurationRequestFilterSensitiveLog = /* @__PURE__ */ __name((obj) => ({  ...obj,  ...obj.propertiesFileContent && { propertiesFileContent: import_smithy_client.SENSITIVE_STRING }}), "CreateWorkerConfigurationRequestFilterSensitiveLog");var DescribeConnectorResponseFilterSensitiveLog = /* @__PURE__ */ __name((obj) => ({  ...obj,  ...obj.connectorConfiguration && { connectorConfiguration: import_smithy_client.SENSITIVE_STRING }}), "DescribeConnectorResponseFilterSensitiveLog");var DescribeConnectorOperationResponseFilterSensitiveLog = /* @__PURE__ */ __name((obj) => ({  ...obj,  ...obj.originConnectorConfiguration && { originConnectorConfiguration: import_smithy_client.SENSITIVE_STRING },  ...obj.targetConnectorConfiguration && { targetConnectorConfiguration: import_smithy_client.SENSITIVE_STRING }}), "DescribeConnectorOperationResponseFilterSensitiveLog");var WorkerConfigurationRevisionDescriptionFilterSensitiveLog = /* @__PURE__ */ __name((obj) => ({  ...obj,  ...obj.propertiesFileContent && { propertiesFileContent: import_smithy_client.SENSITIVE_STRING }}), "WorkerConfigurationRevisionDescriptionFilterSensitiveLog");var DescribeWorkerConfigurationResponseFilterSensitiveLog = /* @__PURE__ */ __name((obj) => ({  ...obj,  ...obj.latestRevision && {    latestRevision: WorkerConfigurationRevisionDescriptionFilterSensitiveLog(obj.latestRevision)  }}), "DescribeWorkerConfigurationResponseFilterSensitiveLog");var UpdateConnectorRequestFilterSensitiveLog = /* @__PURE__ */ __name((obj) => ({  ...obj,  ...obj.connectorConfiguration && { connectorConfiguration: import_smithy_client.SENSITIVE_STRING }}), "UpdateConnectorRequestFilterSensitiveLog"); // src/protocols/Aws_restJson1.tsvar import_core2 = require("@aws-sdk/core");  var se_CreateConnectorCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {    "content-type": "application/json"  };  b.bp("/v1/connectors");  let body;  body = JSON.stringify(    (0, import_smithy_client.take)(input, {      capacity: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "capacity"),      connectorConfiguration: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "connectorConfiguration"),      connectorDescription: [],      connectorName: [],      kafkaCluster: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "kafkaCluster"),      kafkaClusterClientAuthentication: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "kafkaClusterClientAuthentication"),      kafkaClusterEncryptionInTransit: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "kafkaClusterEncryptionInTransit"),      kafkaConnectVersion: [],      logDelivery: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "logDelivery"),      plugins: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "plugins"),      serviceExecutionRoleArn: [],      tags: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "tags"),      workerConfiguration: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "workerConfiguration")    })  );  b.m("POST").h(headers).b(body);  return b.build();}, "se_CreateConnectorCommand");var se_CreateCustomPluginCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {    "content-type": "application/json"  };  b.bp("/v1/custom-plugins");  let body;  body = JSON.stringify(    (0, import_smithy_client.take)(input, {      contentType: [],      description: [],      location: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "location"),      name: [],      tags: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "tags")    })  );  b.m("POST").h(headers).b(body);  return b.build();}, "se_CreateCustomPluginCommand");var se_CreateWorkerConfigurationCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {    "content-type": "application/json"  };  b.bp("/v1/worker-configurations");  let body;  body = JSON.stringify(    (0, import_smithy_client.take)(input, {      description: [],      name: [],      propertiesFileContent: [],      tags: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "tags")    })  );  b.m("POST").h(headers).b(body);  return b.build();}, "se_CreateWorkerConfigurationCommand");var se_DeleteConnectorCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {};  b.bp("/v1/connectors/{connectorArn}");  b.p("connectorArn", () => input.connectorArn, "{connectorArn}", false);  const query = (0, import_smithy_client.map)({    [_cV]: [, input[_cV]]  });  let body;  b.m("DELETE").h(headers).q(query).b(body);  return b.build();}, "se_DeleteConnectorCommand");var se_DeleteCustomPluginCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {};  b.bp("/v1/custom-plugins/{customPluginArn}");  b.p("customPluginArn", () => input.customPluginArn, "{customPluginArn}", false);  let body;  b.m("DELETE").h(headers).b(body);  return b.build();}, "se_DeleteCustomPluginCommand");var se_DeleteWorkerConfigurationCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {};  b.bp("/v1/worker-configurations/{workerConfigurationArn}");  b.p("workerConfigurationArn", () => input.workerConfigurationArn, "{workerConfigurationArn}", false);  let body;  b.m("DELETE").h(headers).b(body);  return b.build();}, "se_DeleteWorkerConfigurationCommand");var se_DescribeConnectorCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {};  b.bp("/v1/connectors/{connectorArn}");  b.p("connectorArn", () => input.connectorArn, "{connectorArn}", false);  let body;  b.m("GET").h(headers).b(body);  return b.build();}, "se_DescribeConnectorCommand");var se_DescribeConnectorOperationCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {};  b.bp("/v1/connectorOperations/{connectorOperationArn}");  b.p("connectorOperationArn", () => input.connectorOperationArn, "{connectorOperationArn}", false);  let body;  b.m("GET").h(headers).b(body);  return b.build();}, "se_DescribeConnectorOperationCommand");var se_DescribeCustomPluginCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {};  b.bp("/v1/custom-plugins/{customPluginArn}");  b.p("customPluginArn", () => input.customPluginArn, "{customPluginArn}", false);  let body;  b.m("GET").h(headers).b(body);  return b.build();}, "se_DescribeCustomPluginCommand");var se_DescribeWorkerConfigurationCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {};  b.bp("/v1/worker-configurations/{workerConfigurationArn}");  b.p("workerConfigurationArn", () => input.workerConfigurationArn, "{workerConfigurationArn}", false);  let body;  b.m("GET").h(headers).b(body);  return b.build();}, "se_DescribeWorkerConfigurationCommand");var se_ListConnectorOperationsCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {};  b.bp("/v1/connectors/{connectorArn}/operations");  b.p("connectorArn", () => input.connectorArn, "{connectorArn}", false);  const query = (0, import_smithy_client.map)({    [_mR]: [() => input.maxResults !== void 0, () => input[_mR].toString()],    [_nT]: [, input[_nT]]  });  let body;  b.m("GET").h(headers).q(query).b(body);  return b.build();}, "se_ListConnectorOperationsCommand");var se_ListConnectorsCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {};  b.bp("/v1/connectors");  const query = (0, import_smithy_client.map)({    [_cNP]: [, input[_cNP]],    [_mR]: [() => input.maxResults !== void 0, () => input[_mR].toString()],    [_nT]: [, input[_nT]]  });  let body;  b.m("GET").h(headers).q(query).b(body);  return b.build();}, "se_ListConnectorsCommand");var se_ListCustomPluginsCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {};  b.bp("/v1/custom-plugins");  const query = (0, import_smithy_client.map)({    [_mR]: [() => input.maxResults !== void 0, () => input[_mR].toString()],    [_nT]: [, input[_nT]],    [_nP]: [, input[_nP]]  });  let body;  b.m("GET").h(headers).q(query).b(body);  return b.build();}, "se_ListCustomPluginsCommand");var se_ListTagsForResourceCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {};  b.bp("/v1/tags/{resourceArn}");  b.p("resourceArn", () => input.resourceArn, "{resourceArn}", false);  let body;  b.m("GET").h(headers).b(body);  return b.build();}, "se_ListTagsForResourceCommand");var se_ListWorkerConfigurationsCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {};  b.bp("/v1/worker-configurations");  const query = (0, import_smithy_client.map)({    [_mR]: [() => input.maxResults !== void 0, () => input[_mR].toString()],    [_nT]: [, input[_nT]],    [_nP]: [, input[_nP]]  });  let body;  b.m("GET").h(headers).q(query).b(body);  return b.build();}, "se_ListWorkerConfigurationsCommand");var se_TagResourceCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {    "content-type": "application/json"  };  b.bp("/v1/tags/{resourceArn}");  b.p("resourceArn", () => input.resourceArn, "{resourceArn}", false);  let body;  body = JSON.stringify(    (0, import_smithy_client.take)(input, {      tags: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "tags")    })  );  b.m("POST").h(headers).b(body);  return b.build();}, "se_TagResourceCommand");var se_UntagResourceCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {};  b.bp("/v1/tags/{resourceArn}");  b.p("resourceArn", () => input.resourceArn, "{resourceArn}", false);  const query = (0, import_smithy_client.map)({    [_tK]: [(0, import_smithy_client.expectNonNull)(input.tagKeys, `tagKeys`) != null, () => input[_tK] || []]  });  let body;  b.m("DELETE").h(headers).q(query).b(body);  return b.build();}, "se_UntagResourceCommand");var se_UpdateConnectorCommand = /* @__PURE__ */ __name(async (input, context) => {  const b = (0, import_core.requestBuilder)(input, context);  const headers = {    "content-type": "application/json"  };  b.bp("/v1/connectors/{connectorArn}");  b.p("connectorArn", () => input.connectorArn, "{connectorArn}", false);  const query = (0, import_smithy_client.map)({    [_cV]: [, (0, import_smithy_client.expectNonNull)(input[_cV], `currentVersion`)]  });  let body;  body = JSON.stringify(    (0, import_smithy_client.take)(input, {      capacity: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "capacity"),      connectorConfiguration: /* @__PURE__ */ __name((_) => (0, import_smithy_client._json)(_), "connectorConfiguration")    })  );  b.m("PUT").h(headers).q(query).b(body);  return b.build();}, "se_UpdateConnectorCommand");var de_CreateConnectorCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode !== 200 && output.statusCode >= 300) {    return de_CommandError(output, context);  }  const contents = (0, import_smithy_client.map)({    $metadata: deserializeMetadata(output)  });  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");  const doc = (0, import_smithy_client.take)(data, {    connectorArn: import_smithy_client.expectString,    connectorName: import_smithy_client.expectString,    connectorState: import_smithy_client.expectString  });  Object.assign(contents, doc);  return contents;}, "de_CreateConnectorCommand");var de_CreateCustomPluginCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode !== 200 && output.statusCode >= 300) {    return de_CommandError(output, context);  }  const contents = (0, import_smithy_client.map)({    $metadata: deserializeMetadata(output)  });  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");  const doc = (0, import_smithy_client.take)(data, {    customPluginArn: import_smithy_client.expectString,    customPluginState: import_smithy_client.expectString,    name: import_smithy_client.expectString,    revision: import_smithy_client.expectLong  });  Object.assign(contents, doc);  return contents;}, "de_CreateCustomPluginCommand");var de_CreateWorkerConfigurationCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode !== 200 && output.statusCode >= 300) {    return de_CommandError(output, context);  }  const contents = (0, import_smithy_client.map)({    $metadata: deserializeMetadata(output)  });  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");  const doc = (0, import_smithy_client.take)(data, {    creationTime: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseRfc3339DateTimeWithOffset)(_)), "creationTime"),    latestRevision: /* @__PURE__ */ __name((_) => de_WorkerConfigurationRevisionSummary(_, context), "latestRevision"),    name: import_smithy_client.expectString,    workerConfigurationArn: import_smithy_client.expectString,    workerConfigurationState: import_smithy_client.expectString  });  Object.assign(contents, doc);  return contents;}, "de_CreateWorkerConfigurationCommand");var de_DeleteConnectorCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode !== 200 && output.statusCode >= 300) {    return de_CommandError(output, context);  }  const contents = (0, import_smithy_client.map)({    $metadata: deserializeMetadata(output)  });  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");  const doc = (0, import_smithy_client.take)(data, {    connectorArn: import_smithy_client.expectString,    connectorState: import_smithy_client.expectString  });  Object.assign(contents, doc);  return contents;}, "de_DeleteConnectorCommand");var de_DeleteCustomPluginCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode !== 200 && output.statusCode >= 300) {    return de_CommandError(output, context);  }  const contents = (0, import_smithy_client.map)({    $metadata: deserializeMetadata(output)  });  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");  const doc = (0, import_smithy_client.take)(data, {    customPluginArn: import_smithy_client.expectString,    customPluginState: import_smithy_client.expectString  });  Object.assign(contents, doc);  return contents;}, "de_DeleteCustomPluginCommand");var de_DeleteWorkerConfigurationCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode !== 200 && output.statusCode >= 300) {    return de_CommandError(output, context);  }  const contents = (0, import_smithy_client.map)({    $metadata: deserializeMetadata(output)  });  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");  const doc = (0, import_smithy_client.take)(data, {    workerConfigurationArn: import_smithy_client.expectString,    workerConfigurationState: import_smithy_client.expectString  });  Object.assign(contents, doc);  return contents;}, "de_DeleteWorkerConfigurationCommand");var de_DescribeConnectorCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode !== 200 && output.statusCode >= 300) {    return de_CommandError(output, context);  }  const contents = (0, import_smithy_client.map)({    $metadata: deserializeMetadata(output)  });  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");  const doc = (0, import_smithy_client.take)(data, {    capacity: import_smithy_client._json,    connectorArn: import_smithy_client.expectString,    connectorConfiguration: import_smithy_client._json,    connectorDescription: import_smithy_client.expectString,    connectorName: import_smithy_client.expectString,    connectorState: import_smithy_client.expectString,    creationTime: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseRfc3339DateTimeWithOffset)(_)), "creationTime"),    currentVersion: import_smithy_client.expectString,    kafkaCluster: import_smithy_client._json,    kafkaClusterClientAuthentication: import_smithy_client._json,    kafkaClusterEncryptionInTransit: import_smithy_client._json,    kafkaConnectVersion: import_smithy_client.expectString,    logDelivery: import_smithy_client._json,    plugins: import_smithy_client._json,    serviceExecutionRoleArn: import_smithy_client.expectString,    stateDescription: import_smithy_client._json,    workerConfiguration: import_smithy_client._json  });  Object.assign(contents, doc);  return contents;}, "de_DescribeConnectorCommand");var de_DescribeConnectorOperationCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode !== 200 && output.statusCode >= 300) {    return de_CommandError(output, context);  }  const contents = (0, import_smithy_client.map)({    $metadata: deserializeMetadata(output)  });  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");  const doc = (0, import_smithy_client.take)(data, {    connectorArn: import_smithy_client.expectString,    connectorOperationArn: import_smithy_client.expectString,    connectorOperationState: import_smithy_client.expectString,    connectorOperationType: import_smithy_client.expectString,    creationTime: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseRfc3339DateTimeWithOffset)(_)), "creationTime"),    endTime: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseRfc3339DateTimeWithOffset)(_)), "endTime"),    errorInfo: import_smithy_client._json,    operationSteps: import_smithy_client._json,    originConnectorConfiguration: import_smithy_client._json,    originWorkerSetting: import_smithy_client._json,    targetConnectorConfiguration: import_smithy_client._json,    targetWorkerSetting: import_smithy_client._json  });  Object.assign(contents, doc);  return contents;}, "de_DescribeConnectorOperationCommand");var de_DescribeCustomPluginCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode !== 200 && output.statusCode >= 300) {    return de_CommandError(output, context);  }  const contents = (0, import_smithy_client.map)({    $metadata: deserializeMetadata(output)  });  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");  const doc = (0, import_smithy_client.take)(data, {    creationTime: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseRfc3339DateTimeWithOffset)(_)), "creationTime"),    customPluginArn: import_smithy_client.expectString,    customPluginState: import_smithy_client.expectString,    description: import_smithy_client.expectString,    latestRevision: /* @__PURE__ */ __name((_) => de_CustomPluginRevisionSummary(_, context), "latestRevision"),    name: import_smithy_client.expectString,    stateDescription: import_smithy_client._json  });  Object.assign(contents, doc);  return contents;}, "de_DescribeCustomPluginCommand");var de_DescribeWorkerConfigurationCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode !== 200 && output.statusCode >= 300) {    return de_CommandError(output, context);  }  const contents = (0, import_smithy_client.map)({    $metadata: deserializeMetadata(output)  });  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");  const doc = (0, import_smithy_client.take)(data, {    creationTime: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseRfc3339DateTimeWithOffset)(_)), "creationTime"),    description: import_smithy_client.expectString,    latestRevision: /* @__PURE__ */ __name((_) => de_WorkerConfigurationRevisionDescription(_, context), "latestRevision"),    name: import_smithy_client.expectString,    workerConfigurationArn: import_smithy_client.expectString,    workerConfigurationState: import_smithy_client.expectString  });  Object.assign(contents, doc);  return contents;}, "de_DescribeWorkerConfigurationCommand");var de_ListConnectorOperationsCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode !== 200 && output.statusCode >= 300) {    return de_CommandError(output, context);  }  const contents = (0, import_smithy_client.map)({    $metadata: deserializeMetadata(output)  });  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");  const doc = (0, import_smithy_client.take)(data, {    connectorOperations: /* @__PURE__ */ __name((_) => de___listOfConnectorOperationSummary(_, context), "connectorOperations"),    nextToken: import_smithy_client.expectString  });  Object.assign(contents, doc);  return contents;}, "de_ListConnectorOperationsCommand");var de_ListConnectorsCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode !== 200 && output.statusCode >= 300) {    return de_CommandError(output, context);  }  const contents = (0, import_smithy_client.map)({    $metadata: deserializeMetadata(output)  });  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");  const doc = (0, import_smithy_client.take)(data, {    connectors: /* @__PURE__ */ __name((_) => de___listOfConnectorSummary(_, context), "connectors"),    nextToken: import_smithy_client.expectString  });  Object.assign(contents, doc);  return contents;}, "de_ListConnectorsCommand");var de_ListCustomPluginsCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode !== 200 && output.statusCode >= 300) {    return de_CommandError(output, context);  }  const contents = (0, import_smithy_client.map)({    $metadata: deserializeMetadata(output)  });  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");  const doc = (0, import_smithy_client.take)(data, {    customPlugins: /* @__PURE__ */ __name((_) => de___listOfCustomPluginSummary(_, context), "customPlugins"),    nextToken: import_smithy_client.expectString  });  Object.assign(contents, doc);  return contents;}, "de_ListCustomPluginsCommand");var de_ListTagsForResourceCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode !== 200 && output.statusCode >= 300) {    return de_CommandError(output, context);  }  const contents = (0, import_smithy_client.map)({    $metadata: deserializeMetadata(output)  });  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");  const doc = (0, import_smithy_client.take)(data, {    tags: import_smithy_client._json  });  Object.assign(contents, doc);  return contents;}, "de_ListTagsForResourceCommand");var de_ListWorkerConfigurationsCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode !== 200 && output.statusCode >= 300) {    return de_CommandError(output, context);  }  const contents = (0, import_smithy_client.map)({    $metadata: deserializeMetadata(output)  });  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");  const doc = (0, import_smithy_client.take)(data, {    nextToken: import_smithy_client.expectString,    workerConfigurations: /* @__PURE__ */ __name((_) => de___listOfWorkerConfigurationSummary(_, context), "workerConfigurations")  });  Object.assign(contents, doc);  return contents;}, "de_ListWorkerConfigurationsCommand");var de_TagResourceCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode !== 200 && output.statusCode >= 300) {    return de_CommandError(output, context);  }  const contents = (0, import_smithy_client.map)({    $metadata: deserializeMetadata(output)  });  await (0, import_smithy_client.collectBody)(output.body, context);  return contents;}, "de_TagResourceCommand");var de_UntagResourceCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode !== 200 && output.statusCode >= 300) {    return de_CommandError(output, context);  }  const contents = (0, import_smithy_client.map)({    $metadata: deserializeMetadata(output)  });  await (0, import_smithy_client.collectBody)(output.body, context);  return contents;}, "de_UntagResourceCommand");var de_UpdateConnectorCommand = /* @__PURE__ */ __name(async (output, context) => {  if (output.statusCode !== 200 && output.statusCode >= 300) {    return de_CommandError(output, context);  }  const contents = (0, import_smithy_client.map)({    $metadata: deserializeMetadata(output)  });  const data = (0, import_smithy_client.expectNonNull)((0, import_smithy_client.expectObject)(await (0, import_core2.parseJsonBody)(output.body, context)), "body");  const doc = (0, import_smithy_client.take)(data, {    connectorArn: import_smithy_client.expectString,    connectorOperationArn: import_smithy_client.expectString,    connectorState: import_smithy_client.expectString  });  Object.assign(contents, doc);  return contents;}, "de_UpdateConnectorCommand");var de_CommandError = /* @__PURE__ */ __name(async (output, context) => {  const parsedOutput = {    ...output,    body: await (0, import_core2.parseJsonErrorBody)(output.body, context)  };  const errorCode = (0, import_core2.loadRestJsonErrorCode)(output, parsedOutput.body);  switch (errorCode) {    case "BadRequestException":    case "com.amazonaws.kafkaconnect#BadRequestException":      throw await de_BadRequestExceptionRes(parsedOutput, context);    case "ConflictException":    case "com.amazonaws.kafkaconnect#ConflictException":      throw await de_ConflictExceptionRes(parsedOutput, context);    case "ForbiddenException":    case "com.amazonaws.kafkaconnect#ForbiddenException":      throw await de_ForbiddenExceptionRes(parsedOutput, context);    case "InternalServerErrorException":    case "com.amazonaws.kafkaconnect#InternalServerErrorException":      throw await de_InternalServerErrorExceptionRes(parsedOutput, context);    case "NotFoundException":    case "com.amazonaws.kafkaconnect#NotFoundException":      throw await de_NotFoundExceptionRes(parsedOutput, context);    case "ServiceUnavailableException":    case "com.amazonaws.kafkaconnect#ServiceUnavailableException":      throw await de_ServiceUnavailableExceptionRes(parsedOutput, context);    case "TooManyRequestsException":    case "com.amazonaws.kafkaconnect#TooManyRequestsException":      throw await de_TooManyRequestsExceptionRes(parsedOutput, context);    case "UnauthorizedException":    case "com.amazonaws.kafkaconnect#UnauthorizedException":      throw await de_UnauthorizedExceptionRes(parsedOutput, context);    default:      const parsedBody = parsedOutput.body;      return throwDefaultError({        output,        parsedBody,        errorCode      });  }}, "de_CommandError");var throwDefaultError = (0, import_smithy_client.withBaseException)(KafkaConnectServiceException);var de_BadRequestExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => {  const contents = (0, import_smithy_client.map)({});  const data = parsedOutput.body;  const doc = (0, import_smithy_client.take)(data, {    message: import_smithy_client.expectString  });  Object.assign(contents, doc);  const exception = new BadRequestException({    $metadata: deserializeMetadata(parsedOutput),    ...contents  });  return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_BadRequestExceptionRes");var de_ConflictExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => {  const contents = (0, import_smithy_client.map)({});  const data = parsedOutput.body;  const doc = (0, import_smithy_client.take)(data, {    message: import_smithy_client.expectString  });  Object.assign(contents, doc);  const exception = new ConflictException({    $metadata: deserializeMetadata(parsedOutput),    ...contents  });  return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_ConflictExceptionRes");var de_ForbiddenExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => {  const contents = (0, import_smithy_client.map)({});  const data = parsedOutput.body;  const doc = (0, import_smithy_client.take)(data, {    message: import_smithy_client.expectString  });  Object.assign(contents, doc);  const exception = new ForbiddenException({    $metadata: deserializeMetadata(parsedOutput),    ...contents  });  return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_ForbiddenExceptionRes");var de_InternalServerErrorExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => {  const contents = (0, import_smithy_client.map)({});  const data = parsedOutput.body;  const doc = (0, import_smithy_client.take)(data, {    message: import_smithy_client.expectString  });  Object.assign(contents, doc);  const exception = new InternalServerErrorException({    $metadata: deserializeMetadata(parsedOutput),    ...contents  });  return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_InternalServerErrorExceptionRes");var de_NotFoundExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => {  const contents = (0, import_smithy_client.map)({});  const data = parsedOutput.body;  const doc = (0, import_smithy_client.take)(data, {    message: import_smithy_client.expectString  });  Object.assign(contents, doc);  const exception = new NotFoundException({    $metadata: deserializeMetadata(parsedOutput),    ...contents  });  return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_NotFoundExceptionRes");var de_ServiceUnavailableExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => {  const contents = (0, import_smithy_client.map)({});  const data = parsedOutput.body;  const doc = (0, import_smithy_client.take)(data, {    message: import_smithy_client.expectString  });  Object.assign(contents, doc);  const exception = new ServiceUnavailableException({    $metadata: deserializeMetadata(parsedOutput),    ...contents  });  return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_ServiceUnavailableExceptionRes");var de_TooManyRequestsExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => {  const contents = (0, import_smithy_client.map)({});  const data = parsedOutput.body;  const doc = (0, import_smithy_client.take)(data, {    message: import_smithy_client.expectString  });  Object.assign(contents, doc);  const exception = new TooManyRequestsException({    $metadata: deserializeMetadata(parsedOutput),    ...contents  });  return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_TooManyRequestsExceptionRes");var de_UnauthorizedExceptionRes = /* @__PURE__ */ __name(async (parsedOutput, context) => {  const contents = (0, import_smithy_client.map)({});  const data = parsedOutput.body;  const doc = (0, import_smithy_client.take)(data, {    message: import_smithy_client.expectString  });  Object.assign(contents, doc);  const exception = new UnauthorizedException({    $metadata: deserializeMetadata(parsedOutput),    ...contents  });  return (0, import_smithy_client.decorateServiceException)(exception, parsedOutput.body);}, "de_UnauthorizedExceptionRes");var de___listOfConnectorOperationSummary = /* @__PURE__ */ __name((output, context) => {  const retVal = (output || []).filter((e) => e != null).map((entry) => {    return de_ConnectorOperationSummary(entry, context);  });  return retVal;}, "de___listOfConnectorOperationSummary");var de___listOfConnectorSummary = /* @__PURE__ */ __name((output, context) => {  const retVal = (output || []).filter((e) => e != null).map((entry) => {    return de_ConnectorSummary(entry, context);  });  return retVal;}, "de___listOfConnectorSummary");var de___listOfCustomPluginSummary = /* @__PURE__ */ __name((output, context) => {  const retVal = (output || []).filter((e) => e != null).map((entry) => {    return de_CustomPluginSummary(entry, context);  });  return retVal;}, "de___listOfCustomPluginSummary");var de___listOfWorkerConfigurationSummary = /* @__PURE__ */ __name((output, context) => {  const retVal = (output || []).filter((e) => e != null).map((entry) => {    return de_WorkerConfigurationSummary(entry, context);  });  return retVal;}, "de___listOfWorkerConfigurationSummary");var de_ConnectorOperationSummary = /* @__PURE__ */ __name((output, context) => {  return (0, import_smithy_client.take)(output, {    connectorOperationArn: import_smithy_client.expectString,    connectorOperationState: import_smithy_client.expectString,    connectorOperationType: import_smithy_client.expectString,    creationTime: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseRfc3339DateTimeWithOffset)(_)), "creationTime"),    endTime: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseRfc3339DateTimeWithOffset)(_)), "endTime")  });}, "de_ConnectorOperationSummary");var de_ConnectorSummary = /* @__PURE__ */ __name((output, context) => {  return (0, import_smithy_client.take)(output, {    capacity: import_smithy_client._json,    connectorArn: import_smithy_client.expectString,    connectorDescription: import_smithy_client.expectString,    connectorName: import_smithy_client.expectString,    connectorState: import_smithy_client.expectString,    creationTime: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseRfc3339DateTimeWithOffset)(_)), "creationTime"),    currentVersion: import_smithy_client.expectString,    kafkaCluster: import_smithy_client._json,    kafkaClusterClientAuthentication: import_smithy_client._json,    kafkaClusterEncryptionInTransit: import_smithy_client._json,    kafkaConnectVersion: import_smithy_client.expectString,    logDelivery: import_smithy_client._json,    plugins: import_smithy_client._json,    serviceExecutionRoleArn: import_smithy_client.expectString,    workerConfiguration: import_smithy_client._json  });}, "de_ConnectorSummary");var de_CustomPluginRevisionSummary = /* @__PURE__ */ __name((output, context) => {  return (0, import_smithy_client.take)(output, {    contentType: import_smithy_client.expectString,    creationTime: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseRfc3339DateTimeWithOffset)(_)), "creationTime"),    description: import_smithy_client.expectString,    fileDescription: import_smithy_client._json,    location: import_smithy_client._json,    revision: import_smithy_client.expectLong  });}, "de_CustomPluginRevisionSummary");var de_CustomPluginSummary = /* @__PURE__ */ __name((output, context) => {  return (0, import_smithy_client.take)(output, {    creationTime: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseRfc3339DateTimeWithOffset)(_)), "creationTime"),    customPluginArn: import_smithy_client.expectString,    customPluginState: import_smithy_client.expectString,    description: import_smithy_client.expectString,    latestRevision: /* @__PURE__ */ __name((_) => de_CustomPluginRevisionSummary(_, context), "latestRevision"),    name: import_smithy_client.expectString  });}, "de_CustomPluginSummary");var de_WorkerConfigurationRevisionDescription = /* @__PURE__ */ __name((output, context) => {  return (0, import_smithy_client.take)(output, {    creationTime: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseRfc3339DateTimeWithOffset)(_)), "creationTime"),    description: import_smithy_client.expectString,    propertiesFileContent: import_smithy_client.expectString,    revision: import_smithy_client.expectLong  });}, "de_WorkerConfigurationRevisionDescription");var de_WorkerConfigurationRevisionSummary = /* @__PURE__ */ __name((output, context) => {  return (0, import_smithy_client.take)(output, {    creationTime: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseRfc3339DateTimeWithOffset)(_)), "creationTime"),    description: import_smithy_client.expectString,    revision: import_smithy_client.expectLong  });}, "de_WorkerConfigurationRevisionSummary");var de_WorkerConfigurationSummary = /* @__PURE__ */ __name((output, context) => {  return (0, import_smithy_client.take)(output, {    creationTime: /* @__PURE__ */ __name((_) => (0, import_smithy_client.expectNonNull)((0, import_smithy_client.parseRfc3339DateTimeWithOffset)(_)), "creationTime"),    description: import_smithy_client.expectString,    latestRevision: /* @__PURE__ */ __name((_) => de_WorkerConfigurationRevisionSummary(_, context), "latestRevision"),    name: import_smithy_client.expectString,    workerConfigurationArn: import_smithy_client.expectString,    workerConfigurationState: import_smithy_client.expectString  });}, "de_WorkerConfigurationSummary");var deserializeMetadata = /* @__PURE__ */ __name((output) => ({  httpStatusCode: output.statusCode,  requestId: output.headers["x-amzn-requestid"] ?? output.headers["x-amzn-request-id"] ?? output.headers["x-amz-request-id"],  extendedRequestId: output.headers["x-amz-id-2"],  cfId: output.headers["x-amz-cf-id"]}), "deserializeMetadata");var _cNP = "connectorNamePrefix";var _cV = "currentVersion";var _mR = "maxResults";var _nP = "namePrefix";var _nT = "nextToken";var _tK = "tagKeys"; // src/commands/CreateConnectorCommand.tsvar CreateConnectorCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("KafkaConnect", "CreateConnector", {}).n("KafkaConnectClient", "CreateConnectorCommand").f(CreateConnectorRequestFilterSensitiveLog, void 0).ser(se_CreateConnectorCommand).de(de_CreateConnectorCommand).build() {  static {    __name(this, "CreateConnectorCommand");  }}; // src/commands/CreateCustomPluginCommand.ts   var CreateCustomPluginCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("KafkaConnect", "CreateCustomPlugin", {}).n("KafkaConnectClient", "CreateCustomPluginCommand").f(void 0, void 0).ser(se_CreateCustomPluginCommand).de(de_CreateCustomPluginCommand).build() {  static {    __name(this, "CreateCustomPluginCommand");  }}; // src/commands/CreateWorkerConfigurationCommand.ts   var CreateWorkerConfigurationCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("KafkaConnect", "CreateWorkerConfiguration", {}).n("KafkaConnectClient", "CreateWorkerConfigurationCommand").f(CreateWorkerConfigurationRequestFilterSensitiveLog, void 0).ser(se_CreateWorkerConfigurationCommand).de(de_CreateWorkerConfigurationCommand).build() {  static {    __name(this, "CreateWorkerConfigurationCommand");  }}; // src/commands/DeleteConnectorCommand.ts   var DeleteConnectorCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("KafkaConnect", "DeleteConnector", {}).n("KafkaConnectClient", "DeleteConnectorCommand").f(void 0, void 0).ser(se_DeleteConnectorCommand).de(de_DeleteConnectorCommand).build() {  static {    __name(this, "DeleteConnectorCommand");  }}; // src/commands/DeleteCustomPluginCommand.ts   var DeleteCustomPluginCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("KafkaConnect", "DeleteCustomPlugin", {}).n("KafkaConnectClient", "DeleteCustomPluginCommand").f(void 0, void 0).ser(se_DeleteCustomPluginCommand).de(de_DeleteCustomPluginCommand).build() {  static {    __name(this, "DeleteCustomPluginCommand");  }}; // src/commands/DeleteWorkerConfigurationCommand.ts   var DeleteWorkerConfigurationCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("KafkaConnect", "DeleteWorkerConfiguration", {}).n("KafkaConnectClient", "DeleteWorkerConfigurationCommand").f(void 0, void 0).ser(se_DeleteWorkerConfigurationCommand).de(de_DeleteWorkerConfigurationCommand).build() {  static {    __name(this, "DeleteWorkerConfigurationCommand");  }}; // src/commands/DescribeConnectorCommand.ts   var DescribeConnectorCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("KafkaConnect", "DescribeConnector", {}).n("KafkaConnectClient", "DescribeConnectorCommand").f(void 0, DescribeConnectorResponseFilterSensitiveLog).ser(se_DescribeConnectorCommand).de(de_DescribeConnectorCommand).build() {  static {    __name(this, "DescribeConnectorCommand");  }}; // src/commands/DescribeConnectorOperationCommand.ts   var DescribeConnectorOperationCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("KafkaConnect", "DescribeConnectorOperation", {}).n("KafkaConnectClient", "DescribeConnectorOperationCommand").f(void 0, DescribeConnectorOperationResponseFilterSensitiveLog).ser(se_DescribeConnectorOperationCommand).de(de_DescribeConnectorOperationCommand).build() {  static {    __name(this, "DescribeConnectorOperationCommand");  }}; // src/commands/DescribeCustomPluginCommand.ts   var DescribeCustomPluginCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("KafkaConnect", "DescribeCustomPlugin", {}).n("KafkaConnectClient", "DescribeCustomPluginCommand").f(void 0, void 0).ser(se_DescribeCustomPluginCommand).de(de_DescribeCustomPluginCommand).build() {  static {    __name(this, "DescribeCustomPluginCommand");  }}; // src/commands/DescribeWorkerConfigurationCommand.ts   var DescribeWorkerConfigurationCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("KafkaConnect", "DescribeWorkerConfiguration", {}).n("KafkaConnectClient", "DescribeWorkerConfigurationCommand").f(void 0, DescribeWorkerConfigurationResponseFilterSensitiveLog).ser(se_DescribeWorkerConfigurationCommand).de(de_DescribeWorkerConfigurationCommand).build() {  static {    __name(this, "DescribeWorkerConfigurationCommand");  }}; // src/commands/ListConnectorOperationsCommand.ts   var ListConnectorOperationsCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("KafkaConnect", "ListConnectorOperations", {}).n("KafkaConnectClient", "ListConnectorOperationsCommand").f(void 0, void 0).ser(se_ListConnectorOperationsCommand).de(de_ListConnectorOperationsCommand).build() {  static {    __name(this, "ListConnectorOperationsCommand");  }}; // src/commands/ListConnectorsCommand.ts   var ListConnectorsCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("KafkaConnect", "ListConnectors", {}).n("KafkaConnectClient", "ListConnectorsCommand").f(void 0, void 0).ser(se_ListConnectorsCommand).de(de_ListConnectorsCommand).build() {  static {    __name(this, "ListConnectorsCommand");  }}; // src/commands/ListCustomPluginsCommand.ts   var ListCustomPluginsCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("KafkaConnect", "ListCustomPlugins", {}).n("KafkaConnectClient", "ListCustomPluginsCommand").f(void 0, void 0).ser(se_ListCustomPluginsCommand).de(de_ListCustomPluginsCommand).build() {  static {    __name(this, "ListCustomPluginsCommand");  }}; // src/commands/ListTagsForResourceCommand.ts   var ListTagsForResourceCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("KafkaConnect", "ListTagsForResource", {}).n("KafkaConnectClient", "ListTagsForResourceCommand").f(void 0, void 0).ser(se_ListTagsForResourceCommand).de(de_ListTagsForResourceCommand).build() {  static {    __name(this, "ListTagsForResourceCommand");  }}; // src/commands/ListWorkerConfigurationsCommand.ts   var ListWorkerConfigurationsCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("KafkaConnect", "ListWorkerConfigurations", {}).n("KafkaConnectClient", "ListWorkerConfigurationsCommand").f(void 0, void 0).ser(se_ListWorkerConfigurationsCommand).de(de_ListWorkerConfigurationsCommand).build() {  static {    __name(this, "ListWorkerConfigurationsCommand");  }}; // src/commands/TagResourceCommand.ts   var TagResourceCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("KafkaConnect", "TagResource", {}).n("KafkaConnectClient", "TagResourceCommand").f(void 0, void 0).ser(se_TagResourceCommand).de(de_TagResourceCommand).build() {  static {    __name(this, "TagResourceCommand");  }}; // src/commands/UntagResourceCommand.ts   var UntagResourceCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("KafkaConnect", "UntagResource", {}).n("KafkaConnectClient", "UntagResourceCommand").f(void 0, void 0).ser(se_UntagResourceCommand).de(de_UntagResourceCommand).build() {  static {    __name(this, "UntagResourceCommand");  }}; // src/commands/UpdateConnectorCommand.ts   var UpdateConnectorCommand = class extends import_smithy_client.Command.classBuilder().ep(commonParams).m(function(Command, cs, config, o) {  return [    (0, import_middleware_serde.getSerdePlugin)(config, this.serialize, this.deserialize),    (0, import_middleware_endpoint.getEndpointPlugin)(config, Command.getEndpointParameterInstructions())  ];}).s("KafkaConnect", "UpdateConnector", {}).n("KafkaConnectClient", "UpdateConnectorCommand").f(UpdateConnectorRequestFilterSensitiveLog, void 0).ser(se_UpdateConnectorCommand).de(de_UpdateConnectorCommand).build() {  static {    __name(this, "UpdateConnectorCommand");  }}; // src/KafkaConnect.tsvar commands = {  CreateConnectorCommand,  CreateCustomPluginCommand,  CreateWorkerConfigurationCommand,  DeleteConnectorCommand,  DeleteCustomPluginCommand,  DeleteWorkerConfigurationCommand,  DescribeConnectorCommand,  DescribeConnectorOperationCommand,  DescribeCustomPluginCommand,  DescribeWorkerConfigurationCommand,  ListConnectorOperationsCommand,  ListConnectorsCommand,  ListCustomPluginsCommand,  ListTagsForResourceCommand,  ListWorkerConfigurationsCommand,  TagResourceCommand,  UntagResourceCommand,  UpdateConnectorCommand};var KafkaConnect = class extends KafkaConnectClient {  static {    __name(this, "KafkaConnect");  }};(0, import_smithy_client.createAggregatedClient)(commands, KafkaConnect); // src/pagination/ListConnectorOperationsPaginator.ts var paginateListConnectorOperations = (0, import_core.createPaginator)(KafkaConnectClient, ListConnectorOperationsCommand, "nextToken", "nextToken", "maxResults"); // src/pagination/ListConnectorsPaginator.ts var paginateListConnectors = (0, import_core.createPaginator)(KafkaConnectClient, ListConnectorsCommand, "nextToken", "nextToken", "maxResults"); // src/pagination/ListCustomPluginsPaginator.ts var paginateListCustomPlugins = (0, import_core.createPaginator)(KafkaConnectClient, ListCustomPluginsCommand, "nextToken", "nextToken", "maxResults"); // src/pagination/ListWorkerConfigurationsPaginator.ts var paginateListWorkerConfigurations = (0, import_core.createPaginator)(KafkaConnectClient, ListWorkerConfigurationsCommand, "nextToken", "nextToken", "maxResults");// Annotate the CommonJS export names for ESM import in node: 0 && (module.exports = {  KafkaConnectServiceException,  __Client,  KafkaConnectClient,  KafkaConnect,  $Command,  CreateConnectorCommand,  CreateCustomPluginCommand,  CreateWorkerConfigurationCommand,  DeleteConnectorCommand,  DeleteCustomPluginCommand,  DeleteWorkerConfigurationCommand,  DescribeConnectorCommand,  DescribeConnectorOperationCommand,  DescribeCustomPluginCommand,  DescribeWorkerConfigurationCommand,  ListConnectorOperationsCommand,  ListConnectorsCommand,  ListCustomPluginsCommand,  ListTagsForResourceCommand,  ListWorkerConfigurationsCommand,  TagResourceCommand,  UntagResourceCommand,  UpdateConnectorCommand,  paginateListConnectorOperations,  paginateListConnectors,  paginateListCustomPlugins,  paginateListWorkerConfigurations,  ConnectorOperationStepState,  ConnectorOperationStepType,  ConnectorOperationState,  ConnectorOperationType,  ConnectorState,  KafkaClusterClientAuthenticationType,  KafkaClusterEncryptionInTransitType,  CustomPluginState,  CustomPluginContentType,  WorkerConfigurationState,  BadRequestException,  ConflictException,  ForbiddenException,  InternalServerErrorException,  NotFoundException,  ServiceUnavailableException,  TooManyRequestsException,  UnauthorizedException,  CreateConnectorRequestFilterSensitiveLog,  CreateWorkerConfigurationRequestFilterSensitiveLog,  DescribeConnectorResponseFilterSensitiveLog,  DescribeConnectorOperationResponseFilterSensitiveLog,  WorkerConfigurationRevisionDescriptionFilterSensitiveLog,  DescribeWorkerConfigurationResponseFilterSensitiveLog,  UpdateConnectorRequestFilterSensitiveLog});