@aws-sdk/client-kafka - npm Package Compare versions

Comparing version 3.42.0 to 3.43.0

dist-cjs/commands/index.js

@@ -33,3 +33,4 @@ "use strict";
 tslib_1.__exportStar(require("./UpdateConfigurationCommand"), exports);
+tslib_1.__exportStar(require("./UpdateConnectivityCommand"), exports);
 tslib_1.__exportStar(require("./UpdateMonitoringCommand"), exports);
 tslib_1.__exportStar(require("./UpdateSecurityCommand"), exports);

dist-cjs/Kafka.js

@@ -33,2 +33,3 @@ "use strict";
 const UpdateConfigurationCommand_1 = require("./commands/UpdateConfigurationCommand");
+const UpdateConnectivityCommand_1 = require("./commands/UpdateConnectivityCommand");
 const UpdateMonitoringCommand_1 = require("./commands/UpdateMonitoringCommand");
@@ -444,2 +445,16 @@ const UpdateSecurityCommand_1 = require("./commands/UpdateSecurityCommand");
     }
+    updateConnectivity(args, optionsOrCb, cb) {
+        const command = new UpdateConnectivityCommand_1.UpdateConnectivityCommand(args);
+        if (typeof optionsOrCb === "function") {
+            this.send(command, optionsOrCb);
+        }
+        else if (typeof cb === "function") {
+            if (typeof optionsOrCb !== "object")
+                throw new Error(`Expect http options but get ${typeof optionsOrCb}`);
+            this.send(command, optionsOrCb || {}, cb);
+        }
+        else {
+            return this.send(command, optionsOrCb);
+        }
+    }
     updateMonitoring(args, optionsOrCb, cb) {
@@ -446,0 +461,0 @@ const command = new UpdateMonitoringCommand_1.UpdateMonitoringCommand(args);

dist-cjs/models/models_0.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.ForbiddenException = exports.BatchAssociateScramSecretResponse = exports.BatchAssociateScramSecretRequest = exports.BadRequestException = exports.UnprocessedScramSecret = exports.NodeInfo = exports.ZookeeperNodeInfo = exports.NodeType = exports.BrokerNodeInfo = exports.KafkaVersion = exports.KafkaVersionStatus = exports.Configuration = exports.ConfigurationState = exports.ConfigurationRevision = exports.CompatibleKafkaVersion = exports.ClusterOperationInfo = exports.MutableClusterInfo = exports.ConfigurationInfo = exports.ClusterOperationStep = exports.ClusterOperationStepInfo = exports.ErrorInfo = exports.ClusterInfo = exports.StateInfo = exports.ClusterState = exports.OpenMonitoring = exports.Prometheus = exports.NodeExporter = exports.JmxExporter = exports.LoggingInfo = exports.BrokerLogs = exports.S3 = exports.Firehose = exports.CloudWatchLogs = exports.EnhancedMonitoring = exports.EncryptionInfo = exports.EncryptionInTransit = exports.ClientBroker = exports.EncryptionAtRest = exports.BrokerSoftwareInfo = exports.ClientAuthentication = exports.Unauthenticated = exports.Tls = exports.Sasl = exports.Scram = exports.Iam = exports.BrokerNodeGroupInfo = exports.StorageInfo = exports.EBSStorageInfo = exports.BrokerAZDistribution = exports.BrokerEBSVolumeInfo = void 0;
-exports.RebootBrokerResponse = exports.RebootBrokerRequest = exports.ListTagsForResourceResponse = exports.ListTagsForResourceRequest = exports.ListScramSecretsResponse = exports.ListScramSecretsRequest = exports.ListNodesResponse = exports.ListNodesRequest = exports.ListKafkaVersionsResponse = exports.ListKafkaVersionsRequest = exports.ListConfigurationsResponse = exports.ListConfigurationsRequest = exports.ListConfigurationRevisionsResponse = exports.ListConfigurationRevisionsRequest = exports.ListClustersResponse = exports.ListClustersRequest = exports.ListClusterOperationsResponse = exports.ListClusterOperationsRequest = exports.GetCompatibleKafkaVersionsResponse = exports.GetCompatibleKafkaVersionsRequest = exports.GetBootstrapBrokersResponse = exports.GetBootstrapBrokersRequest = exports.DescribeConfigurationRevisionResponse = exports.DescribeConfigurationRevisionRequest = exports.DescribeConfigurationResponse = exports.DescribeConfigurationRequest = exports.DescribeClusterOperationResponse = exports.DescribeClusterOperationRequest = exports.DescribeClusterResponse = exports.DescribeClusterRequest = exports.DeleteConfigurationResponse = exports.DeleteConfigurationRequest = exports.DeleteClusterResponse = exports.DeleteClusterRequest = exports.CreateConfigurationResponse = exports.CreateConfigurationRequest = exports.CreateClusterResponse = exports.CreateClusterRequest = exports.OpenMonitoringInfo = exports.PrometheusInfo = exports.NodeExporterInfo = exports.JmxExporterInfo = exports.ConflictException = exports.BatchDisassociateScramSecretResponse = exports.BatchDisassociateScramSecretRequest = exports.UnauthorizedException = exports.TooManyRequestsException = exports.ServiceUnavailableException = exports.NotFoundException = exports.InternalServerErrorException = void 0;
-exports.UpdateSecurityResponse = exports.UpdateSecurityRequest = exports.UpdateMonitoringResponse = exports.UpdateMonitoringRequest = exports.UpdateConfigurationResponse = exports.UpdateConfigurationRequest = exports.UpdateClusterKafkaVersionResponse = exports.UpdateClusterKafkaVersionRequest = exports.UpdateClusterConfigurationResponse = exports.UpdateClusterConfigurationRequest = exports.UpdateBrokerTypeResponse = exports.UpdateBrokerTypeRequest = exports.UpdateBrokerStorageResponse = exports.UpdateBrokerStorageRequest = exports.UpdateBrokerCountResponse = exports.UpdateBrokerCountRequest = exports.UntagResourceRequest = exports.TagResourceRequest = void 0;
+exports.BatchAssociateScramSecretRequest = exports.BadRequestException = exports.UnprocessedScramSecret = exports.NodeInfo = exports.ZookeeperNodeInfo = exports.NodeType = exports.BrokerNodeInfo = exports.KafkaVersion = exports.KafkaVersionStatus = exports.Configuration = exports.ConfigurationState = exports.ConfigurationRevision = exports.CompatibleKafkaVersion = exports.ClusterOperationInfo = exports.MutableClusterInfo = exports.ConfigurationInfo = exports.ClusterOperationStep = exports.ClusterOperationStepInfo = exports.ErrorInfo = exports.ClusterInfo = exports.StateInfo = exports.ClusterState = exports.OpenMonitoring = exports.Prometheus = exports.NodeExporter = exports.JmxExporter = exports.LoggingInfo = exports.BrokerLogs = exports.S3 = exports.Firehose = exports.CloudWatchLogs = exports.EnhancedMonitoring = exports.EncryptionInfo = exports.EncryptionInTransit = exports.ClientBroker = exports.EncryptionAtRest = exports.BrokerSoftwareInfo = exports.ClientAuthentication = exports.Unauthenticated = exports.Tls = exports.Sasl = exports.Scram = exports.Iam = exports.BrokerNodeGroupInfo = exports.StorageInfo = exports.EBSStorageInfo = exports.ConnectivityInfo = exports.PublicAccess = exports.BrokerAZDistribution = exports.BrokerEBSVolumeInfo = void 0;
+exports.ListTagsForResourceResponse = exports.ListTagsForResourceRequest = exports.ListScramSecretsResponse = exports.ListScramSecretsRequest = exports.ListNodesResponse = exports.ListNodesRequest = exports.ListKafkaVersionsResponse = exports.ListKafkaVersionsRequest = exports.ListConfigurationsResponse = exports.ListConfigurationsRequest = exports.ListConfigurationRevisionsResponse = exports.ListConfigurationRevisionsRequest = exports.ListClustersResponse = exports.ListClustersRequest = exports.ListClusterOperationsResponse = exports.ListClusterOperationsRequest = exports.GetCompatibleKafkaVersionsResponse = exports.GetCompatibleKafkaVersionsRequest = exports.GetBootstrapBrokersResponse = exports.GetBootstrapBrokersRequest = exports.DescribeConfigurationRevisionResponse = exports.DescribeConfigurationRevisionRequest = exports.DescribeConfigurationResponse = exports.DescribeConfigurationRequest = exports.DescribeClusterOperationResponse = exports.DescribeClusterOperationRequest = exports.DescribeClusterResponse = exports.DescribeClusterRequest = exports.DeleteConfigurationResponse = exports.DeleteConfigurationRequest = exports.DeleteClusterResponse = exports.DeleteClusterRequest = exports.CreateConfigurationResponse = exports.CreateConfigurationRequest = exports.CreateClusterResponse = exports.CreateClusterRequest = exports.OpenMonitoringInfo = exports.PrometheusInfo = exports.NodeExporterInfo = exports.JmxExporterInfo = exports.ConflictException = exports.BatchDisassociateScramSecretResponse = exports.BatchDisassociateScramSecretRequest = exports.UnauthorizedException = exports.TooManyRequestsException = exports.ServiceUnavailableException = exports.NotFoundException = exports.InternalServerErrorException = exports.ForbiddenException = exports.BatchAssociateScramSecretResponse = void 0;
+exports.UpdateSecurityResponse = exports.UpdateSecurityRequest = exports.UpdateMonitoringResponse = exports.UpdateMonitoringRequest = exports.UpdateConnectivityResponse = exports.UpdateConnectivityRequest = exports.UpdateConfigurationResponse = exports.UpdateConfigurationRequest = exports.UpdateClusterKafkaVersionResponse = exports.UpdateClusterKafkaVersionRequest = exports.UpdateClusterConfigurationResponse = exports.UpdateClusterConfigurationRequest = exports.UpdateBrokerTypeResponse = exports.UpdateBrokerTypeRequest = exports.UpdateBrokerStorageResponse = exports.UpdateBrokerStorageRequest = exports.UpdateBrokerCountResponse = exports.UpdateBrokerCountRequest = exports.UntagResourceRequest = exports.TagResourceRequest = exports.RebootBrokerResponse = exports.RebootBrokerRequest = void 0;
 var BrokerEBSVolumeInfo;
@@ -16,2 +16,14 @@ (function (BrokerEBSVolumeInfo) {
 })(BrokerAZDistribution = exports.BrokerAZDistribution || (exports.BrokerAZDistribution = {}));
+var PublicAccess;
+(function (PublicAccess) {
+    PublicAccess.filterSensitiveLog = (obj) => ({
+        ...obj,
+    });
+})(PublicAccess = exports.PublicAccess || (exports.PublicAccess = {}));
+var ConnectivityInfo;
+(function (ConnectivityInfo) {
+    ConnectivityInfo.filterSensitiveLog = (obj) => ({
+        ...obj,
+    });
+})(ConnectivityInfo = exports.ConnectivityInfo || (exports.ConnectivityInfo = {}));
 var EBSStorageInfo;
@@ -692,2 +704,14 @@ (function (EBSStorageInfo) {
 })(UpdateConfigurationResponse = exports.UpdateConfigurationResponse || (exports.UpdateConfigurationResponse = {}));
+var UpdateConnectivityRequest;
+(function (UpdateConnectivityRequest) {
+    UpdateConnectivityRequest.filterSensitiveLog = (obj) => ({
+        ...obj,
+    });
+})(UpdateConnectivityRequest = exports.UpdateConnectivityRequest || (exports.UpdateConnectivityRequest = {}));
+var UpdateConnectivityResponse;
+(function (UpdateConnectivityResponse) {
+    UpdateConnectivityResponse.filterSensitiveLog = (obj) => ({
+        ...obj,
+    });
+})(UpdateConnectivityResponse = exports.UpdateConnectivityResponse || (exports.UpdateConnectivityResponse = {}));
 var UpdateMonitoringRequest;
@@ -694,0 +718,0 @@ (function (UpdateMonitoringRequest) {

dist-es/commands/index.js

@@ -30,3 +30,4 @@ export * from "./BatchAssociateScramSecretCommand";
 export * from "./UpdateConfigurationCommand";
+export * from "./UpdateConnectivityCommand";
 export * from "./UpdateMonitoringCommand";
 export * from "./UpdateSecurityCommand";

dist-es/Kafka.js

@@ -31,2 +31,3 @@ import { __extends } from "tslib";
 import { UpdateConfigurationCommand, } from "./commands/UpdateConfigurationCommand";
+import { UpdateConnectivityCommand, } from "./commands/UpdateConnectivityCommand";
 import { UpdateMonitoringCommand, } from "./commands/UpdateMonitoringCommand";
@@ -446,2 +447,16 @@ import { UpdateSecurityCommand, } from "./commands/UpdateSecurityCommand";
     };
+    Kafka.prototype.updateConnectivity = function (args, optionsOrCb, cb) {
+        var command = new UpdateConnectivityCommand(args);
+        if (typeof optionsOrCb === "function") {
+            this.send(command, optionsOrCb);
+        }
+        else if (typeof cb === "function") {
+            if (typeof optionsOrCb !== "object")
+                throw new Error("Expect http options but get " + typeof optionsOrCb);
+            this.send(command, optionsOrCb || {}, cb);
+        }
+        else {
+            return this.send(command, optionsOrCb);
+        }
+    };
     Kafka.prototype.updateMonitoring = function (args, optionsOrCb, cb) {
@@ -448,0 +463,0 @@ var command = new UpdateMonitoringCommand(args);

dist-es/models/models_0.js

@@ -10,2 +10,10 @@ import { __assign } from "tslib";
 })(BrokerAZDistribution || (BrokerAZDistribution = {}));
+export var PublicAccess;
+(function (PublicAccess) {
+    PublicAccess.filterSensitiveLog = function (obj) { return (__assign({}, obj)); };
+})(PublicAccess || (PublicAccess = {}));
+export var ConnectivityInfo;
+(function (ConnectivityInfo) {
+    ConnectivityInfo.filterSensitiveLog = function (obj) { return (__assign({}, obj)); };
+})(ConnectivityInfo || (ConnectivityInfo = {}));
 export var EBSStorageInfo;
@@ -474,2 +482,10 @@ (function (EBSStorageInfo) {
 })(UpdateConfigurationResponse || (UpdateConfigurationResponse = {}));
+export var UpdateConnectivityRequest;
+(function (UpdateConnectivityRequest) {
+    UpdateConnectivityRequest.filterSensitiveLog = function (obj) { return (__assign({}, obj)); };
+})(UpdateConnectivityRequest || (UpdateConnectivityRequest = {}));
+export var UpdateConnectivityResponse;
+(function (UpdateConnectivityResponse) {
+    UpdateConnectivityResponse.filterSensitiveLog = function (obj) { return (__assign({}, obj)); };
+})(UpdateConnectivityResponse || (UpdateConnectivityResponse = {}));
 export var UpdateMonitoringRequest;
@@ -476,0 +492,0 @@ (function (UpdateMonitoringRequest) {

dist-types/commands/index.d.ts

@@ -30,3 +30,4 @@ export * from "./BatchAssociateScramSecretCommand";
 export * from "./UpdateConfigurationCommand";
+export * from "./UpdateConnectivityCommand";
 export * from "./UpdateMonitoringCommand";
 export * from "./UpdateSecurityCommand";

dist-types/commands/ListKafkaVersionsCommand.d.ts

@@ -10,3 +10,3 @@ import { Command as $Command } from "@aws-sdk/smithy-client";
 /**
- * <p>Returns a list of Kafka versions.</p>
+ * <p>Returns a list of Apache Kafka versions.</p>
  * @example
@@ -13,0 +13,0 @@ * Use a bare-bones client and the command you need to make an API call.

dist-types/Kafka.d.ts

@@ -31,2 +31,3 @@ import { HttpHandlerOptions as __HttpHandlerOptions } from "@aws-sdk/types";
 import { UpdateConfigurationCommandInput, UpdateConfigurationCommandOutput } from "./commands/UpdateConfigurationCommand";
+import { UpdateConnectivityCommandInput, UpdateConnectivityCommandOutput } from "./commands/UpdateConnectivityCommand";
 import { UpdateMonitoringCommandInput, UpdateMonitoringCommandOutput } from "./commands/UpdateMonitoringCommand";
@@ -136,3 +137,3 @@ import { UpdateSecurityCommandInput, UpdateSecurityCommandOutput } from "./commands/UpdateSecurityCommand";
     /**
-     * <p>Returns a list of Kafka versions.</p>
+     * <p>Returns a list of Apache Kafka versions.</p>
      */
@@ -215,2 +216,8 @@ listKafkaVersions(args: ListKafkaVersionsCommandInput, options?: __HttpHandlerOptions): Promise<ListKafkaVersionsCommandOutput>;
     /**
+     * <p>Updates the cluster's connectivity configuration.</p>
+     */
+    updateConnectivity(args: UpdateConnectivityCommandInput, options?: __HttpHandlerOptions): Promise<UpdateConnectivityCommandOutput>;
+    updateConnectivity(args: UpdateConnectivityCommandInput, cb: (err: any, data?: UpdateConnectivityCommandOutput) => void): void;
+    updateConnectivity(args: UpdateConnectivityCommandInput, options: __HttpHandlerOptions, cb: (err: any, data?: UpdateConnectivityCommandOutput) => void): void;
+    /**
      * <p>Updates the monitoring settings for the cluster. You can use this operation to specify which Apache Kafka metrics you want Amazon MSK to send to Amazon CloudWatch. You can also specify settings for open monitoring with Prometheus.</p>
@@ -217,0 +224,0 @@ */

dist-types/KafkaClient.d.ts

@@ -38,6 +38,7 @@ import { EndpointsInputConfig, EndpointsResolvedConfig, RegionInputConfig, RegionResolvedConfig } from "@aws-sdk/config-resolver";
 import { UpdateConfigurationCommandInput, UpdateConfigurationCommandOutput } from "./commands/UpdateConfigurationCommand";
+import { UpdateConnectivityCommandInput, UpdateConnectivityCommandOutput } from "./commands/UpdateConnectivityCommand";
 import { UpdateMonitoringCommandInput, UpdateMonitoringCommandOutput } from "./commands/UpdateMonitoringCommand";
 import { UpdateSecurityCommandInput, UpdateSecurityCommandOutput } from "./commands/UpdateSecurityCommand";
-export declare type ServiceInputTypes = BatchAssociateScramSecretCommandInput | BatchDisassociateScramSecretCommandInput | CreateClusterCommandInput | CreateConfigurationCommandInput | DeleteClusterCommandInput | DeleteConfigurationCommandInput | DescribeClusterCommandInput | DescribeClusterOperationCommandInput | DescribeConfigurationCommandInput | DescribeConfigurationRevisionCommandInput | GetBootstrapBrokersCommandInput | GetCompatibleKafkaVersionsCommandInput | ListClusterOperationsCommandInput | ListClustersCommandInput | ListConfigurationRevisionsCommandInput | ListConfigurationsCommandInput | ListKafkaVersionsCommandInput | ListNodesCommandInput | ListScramSecretsCommandInput | ListTagsForResourceCommandInput | RebootBrokerCommandInput | TagResourceCommandInput | UntagResourceCommandInput | UpdateBrokerCountCommandInput | UpdateBrokerStorageCommandInput | UpdateBrokerTypeCommandInput | UpdateClusterConfigurationCommandInput | UpdateClusterKafkaVersionCommandInput | UpdateConfigurationCommandInput | UpdateMonitoringCommandInput | UpdateSecurityCommandInput;
-export declare type ServiceOutputTypes = BatchAssociateScramSecretCommandOutput | BatchDisassociateScramSecretCommandOutput | CreateClusterCommandOutput | CreateConfigurationCommandOutput | DeleteClusterCommandOutput | DeleteConfigurationCommandOutput | DescribeClusterCommandOutput | DescribeClusterOperationCommandOutput | DescribeConfigurationCommandOutput | DescribeConfigurationRevisionCommandOutput | GetBootstrapBrokersCommandOutput | GetCompatibleKafkaVersionsCommandOutput | ListClusterOperationsCommandOutput | ListClustersCommandOutput | ListConfigurationRevisionsCommandOutput | ListConfigurationsCommandOutput | ListKafkaVersionsCommandOutput | ListNodesCommandOutput | ListScramSecretsCommandOutput | ListTagsForResourceCommandOutput | RebootBrokerCommandOutput | TagResourceCommandOutput | UntagResourceCommandOutput | UpdateBrokerCountCommandOutput | UpdateBrokerStorageCommandOutput | UpdateBrokerTypeCommandOutput | UpdateClusterConfigurationCommandOutput | UpdateClusterKafkaVersionCommandOutput | UpdateConfigurationCommandOutput | UpdateMonitoringCommandOutput | UpdateSecurityCommandOutput;
+export declare type ServiceInputTypes = BatchAssociateScramSecretCommandInput | BatchDisassociateScramSecretCommandInput | CreateClusterCommandInput | CreateConfigurationCommandInput | DeleteClusterCommandInput | DeleteConfigurationCommandInput | DescribeClusterCommandInput | DescribeClusterOperationCommandInput | DescribeConfigurationCommandInput | DescribeConfigurationRevisionCommandInput | GetBootstrapBrokersCommandInput | GetCompatibleKafkaVersionsCommandInput | ListClusterOperationsCommandInput | ListClustersCommandInput | ListConfigurationRevisionsCommandInput | ListConfigurationsCommandInput | ListKafkaVersionsCommandInput | ListNodesCommandInput | ListScramSecretsCommandInput | ListTagsForResourceCommandInput | RebootBrokerCommandInput | TagResourceCommandInput | UntagResourceCommandInput | UpdateBrokerCountCommandInput | UpdateBrokerStorageCommandInput | UpdateBrokerTypeCommandInput | UpdateClusterConfigurationCommandInput | UpdateClusterKafkaVersionCommandInput | UpdateConfigurationCommandInput | UpdateConnectivityCommandInput | UpdateMonitoringCommandInput | UpdateSecurityCommandInput;
+export declare type ServiceOutputTypes = BatchAssociateScramSecretCommandOutput | BatchDisassociateScramSecretCommandOutput | CreateClusterCommandOutput | CreateConfigurationCommandOutput | DeleteClusterCommandOutput | DeleteConfigurationCommandOutput | DescribeClusterCommandOutput | DescribeClusterOperationCommandOutput | DescribeConfigurationCommandOutput | DescribeConfigurationRevisionCommandOutput | GetBootstrapBrokersCommandOutput | GetCompatibleKafkaVersionsCommandOutput | ListClusterOperationsCommandOutput | ListClustersCommandOutput | ListConfigurationRevisionsCommandOutput | ListConfigurationsCommandOutput | ListKafkaVersionsCommandOutput | ListNodesCommandOutput | ListScramSecretsCommandOutput | ListTagsForResourceCommandOutput | RebootBrokerCommandOutput | TagResourceCommandOutput | UntagResourceCommandOutput | UpdateBrokerCountCommandOutput | UpdateBrokerStorageCommandOutput | UpdateBrokerTypeCommandOutput | UpdateClusterConfigurationCommandOutput | UpdateClusterKafkaVersionCommandOutput | UpdateConfigurationCommandOutput | UpdateConnectivityCommandOutput | UpdateMonitoringCommandOutput | UpdateSecurityCommandOutput;
 export interface ClientDefaults extends Partial<__SmithyResolvedConfiguration<__HttpHandlerOptions>> {
@@ -44,0 +45,0 @@ /**

dist-types/protocols/Aws_restJson1.d.ts

@@ -32,2 +32,3 @@ import { HttpRequest as __HttpRequest, HttpResponse as __HttpResponse } from "@aws-sdk/protocol-http";
 import { UpdateConfigurationCommandInput, UpdateConfigurationCommandOutput } from "../commands/UpdateConfigurationCommand";
+import { UpdateConnectivityCommandInput, UpdateConnectivityCommandOutput } from "../commands/UpdateConnectivityCommand";
 import { UpdateMonitoringCommandInput, UpdateMonitoringCommandOutput } from "../commands/UpdateMonitoringCommand";
@@ -64,2 +65,3 @@ import { UpdateSecurityCommandInput, UpdateSecurityCommandOutput } from "../commands/UpdateSecurityCommand";
 export declare const serializeAws_restJson1UpdateConfigurationCommand: (input: UpdateConfigurationCommandInput, context: __SerdeContext) => Promise<__HttpRequest>;
+export declare const serializeAws_restJson1UpdateConnectivityCommand: (input: UpdateConnectivityCommandInput, context: __SerdeContext) => Promise<__HttpRequest>;
 export declare const serializeAws_restJson1UpdateMonitoringCommand: (input: UpdateMonitoringCommandInput, context: __SerdeContext) => Promise<__HttpRequest>;
@@ -96,3 +98,4 @@ export declare const serializeAws_restJson1UpdateSecurityCommand: (input: UpdateSecurityCommandInput, context: __SerdeContext) => Promise<__HttpRequest>;
 export declare const deserializeAws_restJson1UpdateConfigurationCommand: (output: __HttpResponse, context: __SerdeContext) => Promise<UpdateConfigurationCommandOutput>;
+export declare const deserializeAws_restJson1UpdateConnectivityCommand: (output: __HttpResponse, context: __SerdeContext) => Promise<UpdateConnectivityCommandOutput>;
 export declare const deserializeAws_restJson1UpdateMonitoringCommand: (output: __HttpResponse, context: __SerdeContext) => Promise<UpdateMonitoringCommandOutput>;
 export declare const deserializeAws_restJson1UpdateSecurityCommand: (output: __HttpResponse, context: __SerdeContext) => Promise<UpdateSecurityCommandOutput>;

dist-types/ts3.4/commands/index.d.ts

@@ -30,3 +30,4 @@ export * from "./BatchAssociateScramSecretCommand";
 export * from "./UpdateConfigurationCommand";
+export * from "./UpdateConnectivityCommand";
 export * from "./UpdateMonitoringCommand";
 export * from "./UpdateSecurityCommand";

dist-types/ts3.4/Kafka.d.ts

@@ -31,2 +31,3 @@ import { HttpHandlerOptions as __HttpHandlerOptions } from "@aws-sdk/types";
 import { UpdateConfigurationCommandInput, UpdateConfigurationCommandOutput } from "./commands/UpdateConfigurationCommand";
+import { UpdateConnectivityCommandInput, UpdateConnectivityCommandOutput } from "./commands/UpdateConnectivityCommand";
 import { UpdateMonitoringCommandInput, UpdateMonitoringCommandOutput } from "./commands/UpdateMonitoringCommand";
@@ -154,2 +155,6 @@ import { UpdateSecurityCommandInput, UpdateSecurityCommandOutput } from "./commands/UpdateSecurityCommand";
     
+    updateConnectivity(args: UpdateConnectivityCommandInput, options?: __HttpHandlerOptions): Promise<UpdateConnectivityCommandOutput>;
+    updateConnectivity(args: UpdateConnectivityCommandInput, cb: (err: any, data?: UpdateConnectivityCommandOutput) => void): void;
+    updateConnectivity(args: UpdateConnectivityCommandInput, options: __HttpHandlerOptions, cb: (err: any, data?: UpdateConnectivityCommandOutput) => void): void;
+    
     updateMonitoring(args: UpdateMonitoringCommandInput, options?: __HttpHandlerOptions): Promise<UpdateMonitoringCommandOutput>;
@@ -156,0 +161,0 @@ updateMonitoring(args: UpdateMonitoringCommandInput, cb: (err: any, data?: UpdateMonitoringCommandOutput) => void): void;

dist-types/ts3.4/KafkaClient.d.ts

@@ -38,6 +38,7 @@ import { EndpointsInputConfig, EndpointsResolvedConfig, RegionInputConfig, RegionResolvedConfig } from "@aws-sdk/config-resolver";
 import { UpdateConfigurationCommandInput, UpdateConfigurationCommandOutput } from "./commands/UpdateConfigurationCommand";
+import { UpdateConnectivityCommandInput, UpdateConnectivityCommandOutput } from "./commands/UpdateConnectivityCommand";
 import { UpdateMonitoringCommandInput, UpdateMonitoringCommandOutput } from "./commands/UpdateMonitoringCommand";
 import { UpdateSecurityCommandInput, UpdateSecurityCommandOutput } from "./commands/UpdateSecurityCommand";
-export declare type ServiceInputTypes = BatchAssociateScramSecretCommandInput | BatchDisassociateScramSecretCommandInput | CreateClusterCommandInput | CreateConfigurationCommandInput | DeleteClusterCommandInput | DeleteConfigurationCommandInput | DescribeClusterCommandInput | DescribeClusterOperationCommandInput | DescribeConfigurationCommandInput | DescribeConfigurationRevisionCommandInput | GetBootstrapBrokersCommandInput | GetCompatibleKafkaVersionsCommandInput | ListClusterOperationsCommandInput | ListClustersCommandInput | ListConfigurationRevisionsCommandInput | ListConfigurationsCommandInput | ListKafkaVersionsCommandInput | ListNodesCommandInput | ListScramSecretsCommandInput | ListTagsForResourceCommandInput | RebootBrokerCommandInput | TagResourceCommandInput | UntagResourceCommandInput | UpdateBrokerCountCommandInput | UpdateBrokerStorageCommandInput | UpdateBrokerTypeCommandInput | UpdateClusterConfigurationCommandInput | UpdateClusterKafkaVersionCommandInput | UpdateConfigurationCommandInput | UpdateMonitoringCommandInput | UpdateSecurityCommandInput;
-export declare type ServiceOutputTypes = BatchAssociateScramSecretCommandOutput | BatchDisassociateScramSecretCommandOutput | CreateClusterCommandOutput | CreateConfigurationCommandOutput | DeleteClusterCommandOutput | DeleteConfigurationCommandOutput | DescribeClusterCommandOutput | DescribeClusterOperationCommandOutput | DescribeConfigurationCommandOutput | DescribeConfigurationRevisionCommandOutput | GetBootstrapBrokersCommandOutput | GetCompatibleKafkaVersionsCommandOutput | ListClusterOperationsCommandOutput | ListClustersCommandOutput | ListConfigurationRevisionsCommandOutput | ListConfigurationsCommandOutput | ListKafkaVersionsCommandOutput | ListNodesCommandOutput | ListScramSecretsCommandOutput | ListTagsForResourceCommandOutput | RebootBrokerCommandOutput | TagResourceCommandOutput | UntagResourceCommandOutput | UpdateBrokerCountCommandOutput | UpdateBrokerStorageCommandOutput | UpdateBrokerTypeCommandOutput | UpdateClusterConfigurationCommandOutput | UpdateClusterKafkaVersionCommandOutput | UpdateConfigurationCommandOutput | UpdateMonitoringCommandOutput | UpdateSecurityCommandOutput;
+export declare type ServiceInputTypes = BatchAssociateScramSecretCommandInput | BatchDisassociateScramSecretCommandInput | CreateClusterCommandInput | CreateConfigurationCommandInput | DeleteClusterCommandInput | DeleteConfigurationCommandInput | DescribeClusterCommandInput | DescribeClusterOperationCommandInput | DescribeConfigurationCommandInput | DescribeConfigurationRevisionCommandInput | GetBootstrapBrokersCommandInput | GetCompatibleKafkaVersionsCommandInput | ListClusterOperationsCommandInput | ListClustersCommandInput | ListConfigurationRevisionsCommandInput | ListConfigurationsCommandInput | ListKafkaVersionsCommandInput | ListNodesCommandInput | ListScramSecretsCommandInput | ListTagsForResourceCommandInput | RebootBrokerCommandInput | TagResourceCommandInput | UntagResourceCommandInput | UpdateBrokerCountCommandInput | UpdateBrokerStorageCommandInput | UpdateBrokerTypeCommandInput | UpdateClusterConfigurationCommandInput | UpdateClusterKafkaVersionCommandInput | UpdateConfigurationCommandInput | UpdateConnectivityCommandInput | UpdateMonitoringCommandInput | UpdateSecurityCommandInput;
+export declare type ServiceOutputTypes = BatchAssociateScramSecretCommandOutput | BatchDisassociateScramSecretCommandOutput | CreateClusterCommandOutput | CreateConfigurationCommandOutput | DeleteClusterCommandOutput | DeleteConfigurationCommandOutput | DescribeClusterCommandOutput | DescribeClusterOperationCommandOutput | DescribeConfigurationCommandOutput | DescribeConfigurationRevisionCommandOutput | GetBootstrapBrokersCommandOutput | GetCompatibleKafkaVersionsCommandOutput | ListClusterOperationsCommandOutput | ListClustersCommandOutput | ListConfigurationRevisionsCommandOutput | ListConfigurationsCommandOutput | ListKafkaVersionsCommandOutput | ListNodesCommandOutput | ListScramSecretsCommandOutput | ListTagsForResourceCommandOutput | RebootBrokerCommandOutput | TagResourceCommandOutput | UntagResourceCommandOutput | UpdateBrokerCountCommandOutput | UpdateBrokerStorageCommandOutput | UpdateBrokerTypeCommandOutput | UpdateClusterConfigurationCommandOutput | UpdateClusterKafkaVersionCommandOutput | UpdateConfigurationCommandOutput | UpdateConnectivityCommandOutput | UpdateMonitoringCommandOutput | UpdateSecurityCommandOutput;
 export interface ClientDefaults extends Partial<__SmithyResolvedConfiguration<__HttpHandlerOptions>> {
@@ -44,0 +45,0 @@

dist-types/ts3.4/models/models_0.d.ts

@@ -17,2 +17,20 @@ import { MetadataBearer as $MetadataBearer, SmithyException as __SmithyException } from "@aws-sdk/types";
 
+export interface PublicAccess {
+    
+    Type?: string;
+}
+export declare namespace PublicAccess {
+    
+    const filterSensitiveLog: (obj: PublicAccess) => any;
+}
+
+export interface ConnectivityInfo {
+    
+    PublicAccess?: PublicAccess;
+}
+export declare namespace ConnectivityInfo {
+    
+    const filterSensitiveLog: (obj: ConnectivityInfo) => any;
+}
+
 export interface EBSStorageInfo {
@@ -47,2 +65,4 @@
     StorageInfo?: StorageInfo;
+    
+    ConnectivityInfo?: ConnectivityInfo;
 }
@@ -373,2 +393,4 @@ export declare namespace BrokerNodeGroupInfo {
     EncryptionInfo?: EncryptionInfo;
+    
+    ConnectivityInfo?: ConnectivityInfo;
 }
@@ -937,2 +959,8 @@ export declare namespace MutableClusterInfo {
     BootstrapBrokerStringSaslIam?: string;
+    
+    BootstrapBrokerStringPublicTls?: string;
+    
+    BootstrapBrokerStringPublicSaslScram?: string;
+    
+    BootstrapBrokerStringPublicSaslIam?: string;
 }
@@ -1303,2 +1331,25 @@ export declare namespace GetBootstrapBrokersResponse {
 
+export interface UpdateConnectivityRequest {
+    
+    ClusterArn: string | undefined;
+    
+    ConnectivityInfo: ConnectivityInfo | undefined;
+    
+    CurrentVersion: string | undefined;
+}
+export declare namespace UpdateConnectivityRequest {
+    
+    const filterSensitiveLog: (obj: UpdateConnectivityRequest) => any;
+}
+export interface UpdateConnectivityResponse {
+    
+    ClusterArn?: string;
+    
+    ClusterOperationArn?: string;
+}
+export declare namespace UpdateConnectivityResponse {
+    
+    const filterSensitiveLog: (obj: UpdateConnectivityResponse) => any;
+}
+
 export interface UpdateMonitoringRequest {
@@ -1305,0 +1356,0 @@

dist-types/ts3.4/protocols/Aws_restJson1.d.ts

@@ -32,2 +32,3 @@ import { HttpRequest as __HttpRequest, HttpResponse as __HttpResponse } from "@aws-sdk/protocol-http";
 import { UpdateConfigurationCommandInput, UpdateConfigurationCommandOutput } from "../commands/UpdateConfigurationCommand";
+import { UpdateConnectivityCommandInput, UpdateConnectivityCommandOutput } from "../commands/UpdateConnectivityCommand";
 import { UpdateMonitoringCommandInput, UpdateMonitoringCommandOutput } from "../commands/UpdateMonitoringCommand";
@@ -64,2 +65,3 @@ import { UpdateSecurityCommandInput, UpdateSecurityCommandOutput } from "../commands/UpdateSecurityCommand";
 export declare const serializeAws_restJson1UpdateConfigurationCommand: (input: UpdateConfigurationCommandInput, context: __SerdeContext) => Promise<__HttpRequest>;
+export declare const serializeAws_restJson1UpdateConnectivityCommand: (input: UpdateConnectivityCommandInput, context: __SerdeContext) => Promise<__HttpRequest>;
 export declare const serializeAws_restJson1UpdateMonitoringCommand: (input: UpdateMonitoringCommandInput, context: __SerdeContext) => Promise<__HttpRequest>;
@@ -96,3 +98,4 @@ export declare const serializeAws_restJson1UpdateSecurityCommand: (input: UpdateSecurityCommandInput, context: __SerdeContext) => Promise<__HttpRequest>;
 export declare const deserializeAws_restJson1UpdateConfigurationCommand: (output: __HttpResponse, context: __SerdeContext) => Promise<UpdateConfigurationCommandOutput>;
+export declare const deserializeAws_restJson1UpdateConnectivityCommand: (output: __HttpResponse, context: __SerdeContext) => Promise<UpdateConnectivityCommandOutput>;
 export declare const deserializeAws_restJson1UpdateMonitoringCommand: (output: __HttpResponse, context: __SerdeContext) => Promise<UpdateMonitoringCommandOutput>;
 export declare const deserializeAws_restJson1UpdateSecurityCommand: (output: __HttpResponse, context: __SerdeContext) => Promise<UpdateSecurityCommandOutput>;

package.json

 {
   "name": "@aws-sdk/client-kafka",
   "description": "AWS SDK for JavaScript Kafka Client for Node.js, Browser and React Native",
-  "version": "3.42.0",
+  "version": "3.43.0",
   "scripts": {
@@ -24,3 +24,3 @@ "build": "yarn build:cjs && yarn build:es && yarn build:types",
     "@aws-crypto/sha256-js": "2.0.0",
-    "@aws-sdk/client-sts": "3.42.0",
+    "@aws-sdk/client-sts": "3.43.0",
     "@aws-sdk/config-resolver": "3.40.0",
@@ -27,0 +27,0 @@ "@aws-sdk/credential-provider-node": "3.41.0",

No alert changes

Improved metrics

Total package byte prevSize

1217409

increased by3.05%

Number of package files

216

increased by1.89%

Lines of code

22165

increased by3.26%

Dependency changes

• + Added@aws-sdk/client-sts@3.43.0(transitive)

• - Removed@aws-sdk/client-sts@3.42.0(transitive)

• Updated@aws-sdk/client-sts@3.43.0