updateConnectivity method

Future<UpdateConnectivityResponse> updateConnectivity({ required String clusterArn, required String currentVersion, ConnectivityInfo? connectivityInfo, ZookeeperAccess? zookeeperAccess, })

Updates the cluster's connectivity configuration.

May throw BadRequestException. May throw ForbiddenException. May throw InternalServerErrorException. May throw NotFoundException. May throw ServiceUnavailableException. May throw UnauthorizedException.

Parameter clusterArn : The Amazon Resource Name (ARN) of the configuration.

Parameter currentVersion : The version of the MSK cluster to update. Cluster versions aren't simple numbers. You can describe an MSK cluster to find its version. When this update operation is successful, it generates a new cluster version.

Parameter connectivityInfo : Information about the broker access configuration.

Parameter zookeeperAccess : Access control settings for zookeeper

Implementation

Future<UpdateConnectivityResponse> updateConnectivity({
  required String clusterArn,
  required String currentVersion,
  ConnectivityInfo? connectivityInfo,
  ZookeeperAccess? zookeeperAccess,
}) async {
  final $payload = <String, dynamic>{
    'currentVersion': currentVersion,
    if (connectivityInfo != null) 'connectivityInfo': connectivityInfo,
    if (zookeeperAccess != null) 'zookeeperAccess': zookeeperAccess,
  };
  final response = await _protocol.send(
    payload: $payload,
    method: 'PUT',
    requestUri:
        '/v1/clusters/${Uri.encodeComponent(clusterArn)}/connectivity',
    exceptionFnMap: _exceptionFns,
  );
  return UpdateConnectivityResponse.fromJson(response);
}