File Explorer

/proc/self/root/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 /.

index.js40.6 KB · 1159 lines
'use strict'; var client$1 = require('@aws-sdk/core/client');var core = require('@smithy/core');var client = require('@smithy/core/client');var config = require('@smithy/core/config');var endpoints = require('@smithy/core/endpoints');var protocols = require('@smithy/core/protocols');var retry = require('@smithy/core/retry');var schema = require('@smithy/core/schema');var httpAuthSchemeProvider = require('./auth/httpAuthSchemeProvider');var runtimeConfig = require('./runtimeConfig');var schemas_0 = require('./schemas/schemas_0');var errors = require('./models/errors');var KafkaServiceException = require('./models/KafkaServiceException'); const resolveClientEndpointParameters = (options) => {    return Object.assign(options, {        useDualstackEndpoint: options.useDualstackEndpoint ?? false,        useFipsEndpoint: options.useFipsEndpoint ?? false,        defaultSigningName: "kafka",    });};const commonParams = {    UseFIPS: { type: "builtInParams", name: "useFipsEndpoint" },    Endpoint: { type: "builtInParams", name: "endpoint" },    Region: { type: "builtInParams", name: "region" },    UseDualStack: { type: "builtInParams", name: "useDualstackEndpoint" },}; const getHttpAuthExtensionConfiguration = (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;        },    };};const resolveHttpAuthRuntimeConfig = (config) => {    return {        httpAuthSchemes: config.httpAuthSchemes(),        httpAuthSchemeProvider: config.httpAuthSchemeProvider(),        credentials: config.credentials(),    };}; const resolveRuntimeExtensions = (runtimeConfig, extensions) => {    const extensionConfiguration = Object.assign(client$1.getAwsRegionExtensionConfiguration(runtimeConfig), client.getDefaultExtensionConfiguration(runtimeConfig), protocols.getHttpHandlerExtensionConfiguration(runtimeConfig), getHttpAuthExtensionConfiguration(runtimeConfig));    extensions.forEach((extension) => extension.configure(extensionConfiguration));    return Object.assign(runtimeConfig, client$1.resolveAwsRegionExtensionConfiguration(extensionConfiguration), client.resolveDefaultRuntimeConfig(extensionConfiguration), protocols.resolveHttpHandlerRuntimeConfig(extensionConfiguration), resolveHttpAuthRuntimeConfig(extensionConfiguration));}; class KafkaClient extends client.Client {    config;    constructor(...[configuration]) {        const _config_0 = runtimeConfig.getRuntimeConfig(configuration || {});        super(_config_0);        this.initConfig = _config_0;        const _config_1 = resolveClientEndpointParameters(_config_0);        const _config_2 = client$1.resolveUserAgentConfig(_config_1);        const _config_3 = retry.resolveRetryConfig(_config_2);        const _config_4 = config.resolveRegionConfig(_config_3);        const _config_5 = client$1.resolveHostHeaderConfig(_config_4);        const _config_6 = endpoints.resolveEndpointConfig(_config_5);        const _config_7 = httpAuthSchemeProvider.resolveHttpAuthSchemeConfig(_config_6);        const _config_8 = resolveRuntimeExtensions(_config_7, configuration?.extensions || []);        this.config = _config_8;        this.middlewareStack.use(schema.getSchemaSerdePlugin(this.config));        this.middlewareStack.use(client$1.getUserAgentPlugin(this.config));        this.middlewareStack.use(retry.getRetryPlugin(this.config));        this.middlewareStack.use(protocols.getContentLengthPlugin(this.config));        this.middlewareStack.use(client$1.getHostHeaderPlugin(this.config));        this.middlewareStack.use(client$1.getLoggerPlugin(this.config));        this.middlewareStack.use(client$1.getRecursionDetectionPlugin(this.config));        this.middlewareStack.use(core.getHttpAuthSchemeEndpointRuleSetPlugin(this.config, {            httpAuthSchemeParametersProvider: httpAuthSchemeProvider.defaultKafkaHttpAuthSchemeParametersProvider,            identityProviderConfigProvider: async (config) => new core.DefaultIdentityProviderConfig({                "aws.auth#sigv4": config.credentials,            }),        }));        this.middlewareStack.use(core.getHttpSigningPlugin(this.config));    }    destroy() {        super.destroy();    }} class BatchAssociateScramSecretCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "BatchAssociateScramSecret", {})    .n("KafkaClient", "BatchAssociateScramSecretCommand")    .sc(schemas_0.BatchAssociateScramSecret$)    .build() {} class BatchDisassociateScramSecretCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "BatchDisassociateScramSecret", {})    .n("KafkaClient", "BatchDisassociateScramSecretCommand")    .sc(schemas_0.BatchDisassociateScramSecret$)    .build() {} class CreateClusterCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "CreateCluster", {})    .n("KafkaClient", "CreateClusterCommand")    .sc(schemas_0.CreateCluster$)    .build() {} class CreateClusterV2Command extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "CreateClusterV2", {})    .n("KafkaClient", "CreateClusterV2Command")    .sc(schemas_0.CreateClusterV2$)    .build() {} class CreateConfigurationCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "CreateConfiguration", {})    .n("KafkaClient", "CreateConfigurationCommand")    .sc(schemas_0.CreateConfiguration$)    .build() {} class CreateReplicatorCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "CreateReplicator", {})    .n("KafkaClient", "CreateReplicatorCommand")    .sc(schemas_0.CreateReplicator$)    .build() {} class CreateTopicCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "CreateTopic", {})    .n("KafkaClient", "CreateTopicCommand")    .sc(schemas_0.CreateTopic$)    .build() {} class CreateVpcConnectionCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "CreateVpcConnection", {})    .n("KafkaClient", "CreateVpcConnectionCommand")    .sc(schemas_0.CreateVpcConnection$)    .build() {} class DeleteClusterCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "DeleteCluster", {})    .n("KafkaClient", "DeleteClusterCommand")    .sc(schemas_0.DeleteCluster$)    .build() {} class DeleteClusterPolicyCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "DeleteClusterPolicy", {})    .n("KafkaClient", "DeleteClusterPolicyCommand")    .sc(schemas_0.DeleteClusterPolicy$)    .build() {} class DeleteConfigurationCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "DeleteConfiguration", {})    .n("KafkaClient", "DeleteConfigurationCommand")    .sc(schemas_0.DeleteConfiguration$)    .build() {} class DeleteReplicatorCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "DeleteReplicator", {})    .n("KafkaClient", "DeleteReplicatorCommand")    .sc(schemas_0.DeleteReplicator$)    .build() {} class DeleteTopicCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "DeleteTopic", {})    .n("KafkaClient", "DeleteTopicCommand")    .sc(schemas_0.DeleteTopic$)    .build() {} class DeleteVpcConnectionCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "DeleteVpcConnection", {})    .n("KafkaClient", "DeleteVpcConnectionCommand")    .sc(schemas_0.DeleteVpcConnection$)    .build() {} class DescribeClusterCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "DescribeCluster", {})    .n("KafkaClient", "DescribeClusterCommand")    .sc(schemas_0.DescribeCluster$)    .build() {} class DescribeClusterOperationCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "DescribeClusterOperation", {})    .n("KafkaClient", "DescribeClusterOperationCommand")    .sc(schemas_0.DescribeClusterOperation$)    .build() {} class DescribeClusterOperationV2Command extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "DescribeClusterOperationV2", {})    .n("KafkaClient", "DescribeClusterOperationV2Command")    .sc(schemas_0.DescribeClusterOperationV2$)    .build() {} class DescribeClusterV2Command extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "DescribeClusterV2", {})    .n("KafkaClient", "DescribeClusterV2Command")    .sc(schemas_0.DescribeClusterV2$)    .build() {} class DescribeConfigurationCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "DescribeConfiguration", {})    .n("KafkaClient", "DescribeConfigurationCommand")    .sc(schemas_0.DescribeConfiguration$)    .build() {} class DescribeConfigurationRevisionCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "DescribeConfigurationRevision", {})    .n("KafkaClient", "DescribeConfigurationRevisionCommand")    .sc(schemas_0.DescribeConfigurationRevision$)    .build() {} class DescribeReplicatorCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "DescribeReplicator", {})    .n("KafkaClient", "DescribeReplicatorCommand")    .sc(schemas_0.DescribeReplicator$)    .build() {} class DescribeTopicCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "DescribeTopic", {})    .n("KafkaClient", "DescribeTopicCommand")    .sc(schemas_0.DescribeTopic$)    .build() {} class DescribeTopicPartitionsCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "DescribeTopicPartitions", {})    .n("KafkaClient", "DescribeTopicPartitionsCommand")    .sc(schemas_0.DescribeTopicPartitions$)    .build() {} class DescribeVpcConnectionCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "DescribeVpcConnection", {})    .n("KafkaClient", "DescribeVpcConnectionCommand")    .sc(schemas_0.DescribeVpcConnection$)    .build() {} class GetBootstrapBrokersCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "GetBootstrapBrokers", {})    .n("KafkaClient", "GetBootstrapBrokersCommand")    .sc(schemas_0.GetBootstrapBrokers$)    .build() {} class GetClusterPolicyCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "GetClusterPolicy", {})    .n("KafkaClient", "GetClusterPolicyCommand")    .sc(schemas_0.GetClusterPolicy$)    .build() {} class GetCompatibleKafkaVersionsCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "GetCompatibleKafkaVersions", {})    .n("KafkaClient", "GetCompatibleKafkaVersionsCommand")    .sc(schemas_0.GetCompatibleKafkaVersions$)    .build() {} class ListClientVpcConnectionsCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "ListClientVpcConnections", {})    .n("KafkaClient", "ListClientVpcConnectionsCommand")    .sc(schemas_0.ListClientVpcConnections$)    .build() {} class ListClusterOperationsCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "ListClusterOperations", {})    .n("KafkaClient", "ListClusterOperationsCommand")    .sc(schemas_0.ListClusterOperations$)    .build() {} class ListClusterOperationsV2Command extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "ListClusterOperationsV2", {})    .n("KafkaClient", "ListClusterOperationsV2Command")    .sc(schemas_0.ListClusterOperationsV2$)    .build() {} class ListClustersCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "ListClusters", {})    .n("KafkaClient", "ListClustersCommand")    .sc(schemas_0.ListClusters$)    .build() {} class ListClustersV2Command extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "ListClustersV2", {})    .n("KafkaClient", "ListClustersV2Command")    .sc(schemas_0.ListClustersV2$)    .build() {} class ListConfigurationRevisionsCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "ListConfigurationRevisions", {})    .n("KafkaClient", "ListConfigurationRevisionsCommand")    .sc(schemas_0.ListConfigurationRevisions$)    .build() {} class ListConfigurationsCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "ListConfigurations", {})    .n("KafkaClient", "ListConfigurationsCommand")    .sc(schemas_0.ListConfigurations$)    .build() {} class ListKafkaVersionsCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "ListKafkaVersions", {})    .n("KafkaClient", "ListKafkaVersionsCommand")    .sc(schemas_0.ListKafkaVersions$)    .build() {} class ListNodesCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "ListNodes", {})    .n("KafkaClient", "ListNodesCommand")    .sc(schemas_0.ListNodes$)    .build() {} class ListReplicatorsCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "ListReplicators", {})    .n("KafkaClient", "ListReplicatorsCommand")    .sc(schemas_0.ListReplicators$)    .build() {} class ListScramSecretsCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "ListScramSecrets", {})    .n("KafkaClient", "ListScramSecretsCommand")    .sc(schemas_0.ListScramSecrets$)    .build() {} class ListTagsForResourceCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "ListTagsForResource", {})    .n("KafkaClient", "ListTagsForResourceCommand")    .sc(schemas_0.ListTagsForResource$)    .build() {} class ListTopicsCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "ListTopics", {})    .n("KafkaClient", "ListTopicsCommand")    .sc(schemas_0.ListTopics$)    .build() {} class ListVpcConnectionsCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "ListVpcConnections", {})    .n("KafkaClient", "ListVpcConnectionsCommand")    .sc(schemas_0.ListVpcConnections$)    .build() {} class PutClusterPolicyCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "PutClusterPolicy", {})    .n("KafkaClient", "PutClusterPolicyCommand")    .sc(schemas_0.PutClusterPolicy$)    .build() {} class RebootBrokerCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "RebootBroker", {})    .n("KafkaClient", "RebootBrokerCommand")    .sc(schemas_0.RebootBroker$)    .build() {} class RejectClientVpcConnectionCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "RejectClientVpcConnection", {})    .n("KafkaClient", "RejectClientVpcConnectionCommand")    .sc(schemas_0.RejectClientVpcConnection$)    .build() {} class TagResourceCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "TagResource", {})    .n("KafkaClient", "TagResourceCommand")    .sc(schemas_0.TagResource$)    .build() {} class UntagResourceCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "UntagResource", {})    .n("KafkaClient", "UntagResourceCommand")    .sc(schemas_0.UntagResource$)    .build() {} class UpdateBrokerCountCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "UpdateBrokerCount", {})    .n("KafkaClient", "UpdateBrokerCountCommand")    .sc(schemas_0.UpdateBrokerCount$)    .build() {} class UpdateBrokerStorageCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "UpdateBrokerStorage", {})    .n("KafkaClient", "UpdateBrokerStorageCommand")    .sc(schemas_0.UpdateBrokerStorage$)    .build() {} class UpdateBrokerTypeCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "UpdateBrokerType", {})    .n("KafkaClient", "UpdateBrokerTypeCommand")    .sc(schemas_0.UpdateBrokerType$)    .build() {} class UpdateClusterConfigurationCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "UpdateClusterConfiguration", {})    .n("KafkaClient", "UpdateClusterConfigurationCommand")    .sc(schemas_0.UpdateClusterConfiguration$)    .build() {} class UpdateClusterKafkaVersionCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "UpdateClusterKafkaVersion", {})    .n("KafkaClient", "UpdateClusterKafkaVersionCommand")    .sc(schemas_0.UpdateClusterKafkaVersion$)    .build() {} class UpdateConfigurationCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "UpdateConfiguration", {})    .n("KafkaClient", "UpdateConfigurationCommand")    .sc(schemas_0.UpdateConfiguration$)    .build() {} class UpdateConnectivityCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "UpdateConnectivity", {})    .n("KafkaClient", "UpdateConnectivityCommand")    .sc(schemas_0.UpdateConnectivity$)    .build() {} class UpdateMonitoringCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "UpdateMonitoring", {})    .n("KafkaClient", "UpdateMonitoringCommand")    .sc(schemas_0.UpdateMonitoring$)    .build() {} class UpdateRebalancingCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "UpdateRebalancing", {})    .n("KafkaClient", "UpdateRebalancingCommand")    .sc(schemas_0.UpdateRebalancing$)    .build() {} class UpdateReplicationInfoCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "UpdateReplicationInfo", {})    .n("KafkaClient", "UpdateReplicationInfoCommand")    .sc(schemas_0.UpdateReplicationInfo$)    .build() {} class UpdateSecurityCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "UpdateSecurity", {})    .n("KafkaClient", "UpdateSecurityCommand")    .sc(schemas_0.UpdateSecurity$)    .build() {} class UpdateStorageCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "UpdateStorage", {})    .n("KafkaClient", "UpdateStorageCommand")    .sc(schemas_0.UpdateStorage$)    .build() {} class UpdateTopicCommand extends client.Command    .classBuilder()    .ep(commonParams)    .m(function (Command, cs, config, o) {    return [endpoints.getEndpointPlugin(config, Command.getEndpointParameterInstructions())];})    .s("Kafka", "UpdateTopic", {})    .n("KafkaClient", "UpdateTopicCommand")    .sc(schemas_0.UpdateTopic$)    .build() {} const paginateDescribeTopicPartitions = core.createPaginator(KafkaClient, DescribeTopicPartitionsCommand, "NextToken", "NextToken", "MaxResults"); const paginateListClientVpcConnections = core.createPaginator(KafkaClient, ListClientVpcConnectionsCommand, "NextToken", "NextToken", "MaxResults"); const paginateListClusterOperations = core.createPaginator(KafkaClient, ListClusterOperationsCommand, "NextToken", "NextToken", "MaxResults"); const paginateListClusterOperationsV2 = core.createPaginator(KafkaClient, ListClusterOperationsV2Command, "NextToken", "NextToken", "MaxResults"); const paginateListClusters = core.createPaginator(KafkaClient, ListClustersCommand, "NextToken", "NextToken", "MaxResults"); const paginateListClustersV2 = core.createPaginator(KafkaClient, ListClustersV2Command, "NextToken", "NextToken", "MaxResults"); const paginateListConfigurationRevisions = core.createPaginator(KafkaClient, ListConfigurationRevisionsCommand, "NextToken", "NextToken", "MaxResults"); const paginateListConfigurations = core.createPaginator(KafkaClient, ListConfigurationsCommand, "NextToken", "NextToken", "MaxResults"); const paginateListKafkaVersions = core.createPaginator(KafkaClient, ListKafkaVersionsCommand, "NextToken", "NextToken", "MaxResults"); const paginateListNodes = core.createPaginator(KafkaClient, ListNodesCommand, "NextToken", "NextToken", "MaxResults"); const paginateListReplicators = core.createPaginator(KafkaClient, ListReplicatorsCommand, "NextToken", "NextToken", "MaxResults"); const paginateListScramSecrets = core.createPaginator(KafkaClient, ListScramSecretsCommand, "NextToken", "NextToken", "MaxResults"); const paginateListTopics = core.createPaginator(KafkaClient, ListTopicsCommand, "NextToken", "NextToken", "MaxResults"); const paginateListVpcConnections = core.createPaginator(KafkaClient, ListVpcConnectionsCommand, "NextToken", "NextToken", "MaxResults"); const commands = {    BatchAssociateScramSecretCommand,    BatchDisassociateScramSecretCommand,    CreateClusterCommand,    CreateClusterV2Command,    CreateConfigurationCommand,    CreateReplicatorCommand,    CreateTopicCommand,    CreateVpcConnectionCommand,    DeleteClusterCommand,    DeleteClusterPolicyCommand,    DeleteConfigurationCommand,    DeleteReplicatorCommand,    DeleteTopicCommand,    DeleteVpcConnectionCommand,    DescribeClusterCommand,    DescribeClusterOperationCommand,    DescribeClusterOperationV2Command,    DescribeClusterV2Command,    DescribeConfigurationCommand,    DescribeConfigurationRevisionCommand,    DescribeReplicatorCommand,    DescribeTopicCommand,    DescribeTopicPartitionsCommand,    DescribeVpcConnectionCommand,    GetBootstrapBrokersCommand,    GetClusterPolicyCommand,    GetCompatibleKafkaVersionsCommand,    ListClientVpcConnectionsCommand,    ListClusterOperationsCommand,    ListClusterOperationsV2Command,    ListClustersCommand,    ListClustersV2Command,    ListConfigurationRevisionsCommand,    ListConfigurationsCommand,    ListKafkaVersionsCommand,    ListNodesCommand,    ListReplicatorsCommand,    ListScramSecretsCommand,    ListTagsForResourceCommand,    ListTopicsCommand,    ListVpcConnectionsCommand,    PutClusterPolicyCommand,    RebootBrokerCommand,    RejectClientVpcConnectionCommand,    TagResourceCommand,    UntagResourceCommand,    UpdateBrokerCountCommand,    UpdateBrokerStorageCommand,    UpdateBrokerTypeCommand,    UpdateClusterConfigurationCommand,    UpdateClusterKafkaVersionCommand,    UpdateConfigurationCommand,    UpdateConnectivityCommand,    UpdateMonitoringCommand,    UpdateRebalancingCommand,    UpdateReplicationInfoCommand,    UpdateSecurityCommand,    UpdateStorageCommand,    UpdateTopicCommand,};const paginators = {    paginateDescribeTopicPartitions,    paginateListClientVpcConnections,    paginateListClusterOperations,    paginateListClusterOperationsV2,    paginateListClusters,    paginateListClustersV2,    paginateListConfigurationRevisions,    paginateListConfigurations,    paginateListKafkaVersions,    paginateListNodes,    paginateListReplicators,    paginateListScramSecrets,    paginateListTopics,    paginateListVpcConnections,};class Kafka extends KafkaClient {}client.createAggregatedClient(commands, Kafka, { paginators }); const VpcConnectionState = {    AVAILABLE: "AVAILABLE",    CREATING: "CREATING",    DEACTIVATING: "DEACTIVATING",    DELETING: "DELETING",    FAILED: "FAILED",    INACTIVE: "INACTIVE",    REJECTED: "REJECTED",    REJECTING: "REJECTING",};const ClusterType = {    PROVISIONED: "PROVISIONED",    SERVERLESS: "SERVERLESS",};const BrokerAZDistribution = {    DEFAULT: "DEFAULT",};const NetworkType = {    DUAL: "DUAL",    IPV4: "IPV4",};const CustomerActionStatus = {    ACTION_RECOMMENDED: "ACTION_RECOMMENDED",    CRITICAL_ACTION_REQUIRED: "CRITICAL_ACTION_REQUIRED",    NONE: "NONE",};const ClientBroker = {    PLAINTEXT: "PLAINTEXT",    TLS: "TLS",    TLS_PLAINTEXT: "TLS_PLAINTEXT",};const EnhancedMonitoring = {    DEFAULT: "DEFAULT",    PER_BROKER: "PER_BROKER",    PER_TOPIC_PER_BROKER: "PER_TOPIC_PER_BROKER",    PER_TOPIC_PER_PARTITION: "PER_TOPIC_PER_PARTITION",};const RebalancingStatus = {    ACTIVE: "ACTIVE",    PAUSED: "PAUSED",};const StorageMode = {    LOCAL: "LOCAL",    TIERED: "TIERED",};const ClusterState = {    ACTIVE: "ACTIVE",    CREATING: "CREATING",    DELETING: "DELETING",    FAILED: "FAILED",    HEALING: "HEALING",    MAINTENANCE: "MAINTENANCE",    REBOOTING_BROKER: "REBOOTING_BROKER",    UPDATING: "UPDATING",};const UserIdentityType = {    AWSACCOUNT: "AWSACCOUNT",    AWSSERVICE: "AWSSERVICE",};const ConfigurationState = {    ACTIVE: "ACTIVE",    DELETE_FAILED: "DELETE_FAILED",    DELETING: "DELETING",};const KafkaClusterSaslScramMechanism = {    SHA256: "SHA256",    SHA512: "SHA512",};const KafkaClusterEncryptionInTransitType = {    TLS: "TLS",};const KafkaVersionStatus = {    ACTIVE: "ACTIVE",    DEPRECATED: "DEPRECATED",};const NodeType = {    BROKER: "BROKER",};const ConsumerGroupOffsetSyncMode = {    ENHANCED: "ENHANCED",    LEGACY: "LEGACY",};const TargetCompressionType = {    GZIP: "GZIP",    LZ4: "LZ4",    NONE: "NONE",    SNAPPY: "SNAPPY",    ZSTD: "ZSTD",};const ReplicationStartingPositionType = {    EARLIEST: "EARLIEST",    LATEST: "LATEST",};const ReplicationTopicNameConfigurationType = {    IDENTICAL: "IDENTICAL",    PREFIXED_WITH_SOURCE_CLUSTER_ALIAS: "PREFIXED_WITH_SOURCE_CLUSTER_ALIAS",};const ReplicatorState = {    CREATING: "CREATING",    DELETING: "DELETING",    FAILED: "FAILED",    RUNNING: "RUNNING",    UPDATING: "UPDATING",};const TopicState = {    ACTIVE: "ACTIVE",    CREATING: "CREATING",    DELETING: "DELETING",    UPDATING: "UPDATING",}; exports.$Command = client.Command;exports.__Client = client.Client;exports.KafkaServiceException = KafkaServiceException.KafkaServiceException;exports.BatchAssociateScramSecretCommand = BatchAssociateScramSecretCommand;exports.BatchDisassociateScramSecretCommand = BatchDisassociateScramSecretCommand;exports.BrokerAZDistribution = BrokerAZDistribution;exports.ClientBroker = ClientBroker;exports.ClusterState = ClusterState;exports.ClusterType = ClusterType;exports.ConfigurationState = ConfigurationState;exports.ConsumerGroupOffsetSyncMode = ConsumerGroupOffsetSyncMode;exports.CreateClusterCommand = CreateClusterCommand;exports.CreateClusterV2Command = CreateClusterV2Command;exports.CreateConfigurationCommand = CreateConfigurationCommand;exports.CreateReplicatorCommand = CreateReplicatorCommand;exports.CreateTopicCommand = CreateTopicCommand;exports.CreateVpcConnectionCommand = CreateVpcConnectionCommand;exports.CustomerActionStatus = CustomerActionStatus;exports.DeleteClusterCommand = DeleteClusterCommand;exports.DeleteClusterPolicyCommand = DeleteClusterPolicyCommand;exports.DeleteConfigurationCommand = DeleteConfigurationCommand;exports.DeleteReplicatorCommand = DeleteReplicatorCommand;exports.DeleteTopicCommand = DeleteTopicCommand;exports.DeleteVpcConnectionCommand = DeleteVpcConnectionCommand;exports.DescribeClusterCommand = DescribeClusterCommand;exports.DescribeClusterOperationCommand = DescribeClusterOperationCommand;exports.DescribeClusterOperationV2Command = DescribeClusterOperationV2Command;exports.DescribeClusterV2Command = DescribeClusterV2Command;exports.DescribeConfigurationCommand = DescribeConfigurationCommand;exports.DescribeConfigurationRevisionCommand = DescribeConfigurationRevisionCommand;exports.DescribeReplicatorCommand = DescribeReplicatorCommand;exports.DescribeTopicCommand = DescribeTopicCommand;exports.DescribeTopicPartitionsCommand = DescribeTopicPartitionsCommand;exports.DescribeVpcConnectionCommand = DescribeVpcConnectionCommand;exports.EnhancedMonitoring = EnhancedMonitoring;exports.GetBootstrapBrokersCommand = GetBootstrapBrokersCommand;exports.GetClusterPolicyCommand = GetClusterPolicyCommand;exports.GetCompatibleKafkaVersionsCommand = GetCompatibleKafkaVersionsCommand;exports.Kafka = Kafka;exports.KafkaClient = KafkaClient;exports.KafkaClusterEncryptionInTransitType = KafkaClusterEncryptionInTransitType;exports.KafkaClusterSaslScramMechanism = KafkaClusterSaslScramMechanism;exports.KafkaVersionStatus = KafkaVersionStatus;exports.ListClientVpcConnectionsCommand = ListClientVpcConnectionsCommand;exports.ListClusterOperationsCommand = ListClusterOperationsCommand;exports.ListClusterOperationsV2Command = ListClusterOperationsV2Command;exports.ListClustersCommand = ListClustersCommand;exports.ListClustersV2Command = ListClustersV2Command;exports.ListConfigurationRevisionsCommand = ListConfigurationRevisionsCommand;exports.ListConfigurationsCommand = ListConfigurationsCommand;exports.ListKafkaVersionsCommand = ListKafkaVersionsCommand;exports.ListNodesCommand = ListNodesCommand;exports.ListReplicatorsCommand = ListReplicatorsCommand;exports.ListScramSecretsCommand = ListScramSecretsCommand;exports.ListTagsForResourceCommand = ListTagsForResourceCommand;exports.ListTopicsCommand = ListTopicsCommand;exports.ListVpcConnectionsCommand = ListVpcConnectionsCommand;exports.NetworkType = NetworkType;exports.NodeType = NodeType;exports.PutClusterPolicyCommand = PutClusterPolicyCommand;exports.RebalancingStatus = RebalancingStatus;exports.RebootBrokerCommand = RebootBrokerCommand;exports.RejectClientVpcConnectionCommand = RejectClientVpcConnectionCommand;exports.ReplicationStartingPositionType = ReplicationStartingPositionType;exports.ReplicationTopicNameConfigurationType = ReplicationTopicNameConfigurationType;exports.ReplicatorState = ReplicatorState;exports.StorageMode = StorageMode;exports.TagResourceCommand = TagResourceCommand;exports.TargetCompressionType = TargetCompressionType;exports.TopicState = TopicState;exports.UntagResourceCommand = UntagResourceCommand;exports.UpdateBrokerCountCommand = UpdateBrokerCountCommand;exports.UpdateBrokerStorageCommand = UpdateBrokerStorageCommand;exports.UpdateBrokerTypeCommand = UpdateBrokerTypeCommand;exports.UpdateClusterConfigurationCommand = UpdateClusterConfigurationCommand;exports.UpdateClusterKafkaVersionCommand = UpdateClusterKafkaVersionCommand;exports.UpdateConfigurationCommand = UpdateConfigurationCommand;exports.UpdateConnectivityCommand = UpdateConnectivityCommand;exports.UpdateMonitoringCommand = UpdateMonitoringCommand;exports.UpdateRebalancingCommand = UpdateRebalancingCommand;exports.UpdateReplicationInfoCommand = UpdateReplicationInfoCommand;exports.UpdateSecurityCommand = UpdateSecurityCommand;exports.UpdateStorageCommand = UpdateStorageCommand;exports.UpdateTopicCommand = UpdateTopicCommand;exports.UserIdentityType = UserIdentityType;exports.VpcConnectionState = VpcConnectionState;exports.paginateDescribeTopicPartitions = paginateDescribeTopicPartitions;exports.paginateListClientVpcConnections = paginateListClientVpcConnections;exports.paginateListClusterOperations = paginateListClusterOperations;exports.paginateListClusterOperationsV2 = paginateListClusterOperationsV2;exports.paginateListClusters = paginateListClusters;exports.paginateListClustersV2 = paginateListClustersV2;exports.paginateListConfigurationRevisions = paginateListConfigurationRevisions;exports.paginateListConfigurations = paginateListConfigurations;exports.paginateListKafkaVersions = paginateListKafkaVersions;exports.paginateListNodes = paginateListNodes;exports.paginateListReplicators = paginateListReplicators;exports.paginateListScramSecrets = paginateListScramSecrets;exports.paginateListTopics = paginateListTopics;exports.paginateListVpcConnections = paginateListVpcConnections;Object.prototype.hasOwnProperty.call(schemas_0, '__proto__') &&    !Object.prototype.hasOwnProperty.call(exports, '__proto__') &&    Object.defineProperty(exports, '__proto__', {        enumerable: true,        value: schemas_0['__proto__']    }); Object.keys(schemas_0).forEach(function (k) {    if (k !== 'default' && !Object.prototype.hasOwnProperty.call(exports, k)) exports[k] = schemas_0[k];});Object.prototype.hasOwnProperty.call(errors, '__proto__') &&    !Object.prototype.hasOwnProperty.call(exports, '__proto__') &&    Object.defineProperty(exports, '__proto__', {        enumerable: true,        value: errors['__proto__']    }); Object.keys(errors).forEach(function (k) {    if (k !== 'default' && !Object.prototype.hasOwnProperty.call(exports, k)) exports[k] = errors[k];});