Google Cloud Managed Kafka V1 Client - Class ManagedKafkaConnectClient (0.4.0)

Stay organized with collections Save and categorize content based on your preferences.

use Google\ApiCore\ApiException;
use Google\ApiCore\OperationResponse;
use Google\Cloud\ManagedKafka\V1\CapacityConfig;
use Google\Cloud\ManagedKafka\V1\Client\ManagedKafkaConnectClient;
use Google\Cloud\ManagedKafka\V1\ConnectAccessConfig;
use Google\Cloud\ManagedKafka\V1\ConnectCluster;
use Google\Cloud\ManagedKafka\V1\ConnectGcpConfig;
use Google\Cloud\ManagedKafka\V1\ConnectNetworkConfig;
use Google\Cloud\ManagedKafka\V1\CreateConnectClusterRequest;
use Google\Rpc\Status;

/**
 * @param string $formattedParent                                                The parent project/location in which to create the Kafka Connect
 *                                                                               cluster. Structured like
 *                                                                               `projects/{project}/locations/{location}/`. Please see
 *                                                                               {@see ManagedKafkaConnectClient::locationName()} for help formatting this field.
 * @param string $connectClusterId                                               The ID to use for the Connect cluster, which will become the
 *                                                                               final component of the cluster's name. The ID must be 1-63 characters long,
 *                                                                               and match the regular expression `[a-z]([-a-z0-9]*[a-z0-9])?` to comply
 *                                                                               with RFC 1035.
 *
 *                                                                               This value is structured like: `my-cluster-id`.
 * @param string $connectClusterGcpConfigAccessConfigNetworkConfigsPrimarySubnet VPC subnet to make available to the Kafka Connect cluster.
 *                                                                               Structured like:
 *                                                                               projects/{project}/regions/{region}/subnetworks/{subnet_id}
 *
 *                                                                               It is used to create a Private Service Connect (PSC) interface for the
 *                                                                               Kafka Connect workers. It must be located in the same region as the
 *                                                                               Kafka Connect cluster.
 *
 *                                                                               The CIDR range of the subnet must be within the IPv4 address ranges for
 *                                                                               private networks, as specified in RFC 1918. The primary subnet CIDR range
 *                                                                               must have a minimum size of /22 (1024 addresses).
 * @param string $connectClusterKafkaCluster                                     Immutable. The name of the Kafka cluster this Kafka Connect
 *                                                                               cluster is attached to. Structured like:
 *                                                                               projects/{project}/locations/{location}/clusters/{cluster}
 * @param int    $connectClusterCapacityConfigVcpuCount                          The number of vCPUs to provision for the cluster. Minimum: 3.
 * @param int    $connectClusterCapacityConfigMemoryBytes                        The memory to provision for the cluster in bytes.
 *                                                                               The CPU:memory ratio (vCPU:GiB) must be between 1:1 and 1:8.
 *                                                                               Minimum: 3221225472 (3 GiB).
 */
function create_connect_cluster_sample(
    string $formattedParent,
    string $connectClusterId,
    string $connectClusterGcpConfigAccessConfigNetworkConfigsPrimarySubnet,
    string $connectClusterKafkaCluster,
    int $connectClusterCapacityConfigVcpuCount,
    int $connectClusterCapacityConfigMemoryBytes
): void {
    // Create a client.
    $managedKafkaConnectClient = new ManagedKafkaConnectClient();

    // Prepare the request message.
    $connectNetworkConfig = (new ConnectNetworkConfig())
        ->setPrimarySubnet($connectClusterGcpConfigAccessConfigNetworkConfigsPrimarySubnet);
    $connectClusterGcpConfigAccessConfigNetworkConfigs = [$connectNetworkConfig,];
    $connectClusterGcpConfigAccessConfig = (new ConnectAccessConfig())
        ->setNetworkConfigs($connectClusterGcpConfigAccessConfigNetworkConfigs);
    $connectClusterGcpConfig = (new ConnectGcpConfig())
        ->setAccessConfig($connectClusterGcpConfigAccessConfig);
    $connectClusterCapacityConfig = (new CapacityConfig())
        ->setVcpuCount($connectClusterCapacityConfigVcpuCount)
        ->setMemoryBytes($connectClusterCapacityConfigMemoryBytes);
    $connectCluster = (new ConnectCluster())
        ->setGcpConfig($connectClusterGcpConfig)
        ->setKafkaCluster($connectClusterKafkaCluster)
        ->setCapacityConfig($connectClusterCapacityConfig);
    $request = (new CreateConnectClusterRequest())
        ->setParent($formattedParent)
        ->setConnectClusterId($connectClusterId)
        ->setConnectCluster($connectCluster);

    // Call the API and handle any network failures.
    try {
        /** @var OperationResponse $response */
        $response = $managedKafkaConnectClient->createConnectCluster($request);
        $response->pollUntilComplete();

        if ($response->operationSucceeded()) {
            /** @var ConnectCluster $result */
            $result = $response->getResult();
            printf('Operation successful with response data: %s' . PHP_EOL, $result->serializeToJsonString());
        } else {
            /** @var Status $error */
            $error = $response->getError();
            printf('Operation failed with error data: %s' . PHP_EOL, $error->serializeToJsonString());
        }
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

/**
 * Helper to execute the sample.
 *
 * This sample has been automatically generated and should be regarded as a code
 * template only. It will require modifications to work:
 *  - It may require correct/in-range values for request initialization.
 *  - It may require specifying regional endpoints when creating the service client,
 *    please see the apiEndpoint client configuration option for more details.
 */
function callSample(): void
{
    $formattedParent = ManagedKafkaConnectClient::locationName('[PROJECT]', '[LOCATION]');
    $connectClusterId = '[CONNECT_CLUSTER_ID]';
    $connectClusterGcpConfigAccessConfigNetworkConfigsPrimarySubnet = '[PRIMARY_SUBNET]';
    $connectClusterKafkaCluster = '[KAFKA_CLUSTER]';
    $connectClusterCapacityConfigVcpuCount = 0;
    $connectClusterCapacityConfigMemoryBytes = 0;

    create_connect_cluster_sample(
        $formattedParent,
        $connectClusterId,
        $connectClusterGcpConfigAccessConfigNetworkConfigsPrimarySubnet,
        $connectClusterKafkaCluster,
        $connectClusterCapacityConfigVcpuCount,
        $connectClusterCapacityConfigMemoryBytes
    );
}

use Google\ApiCore\ApiException;
use Google\Cloud\ManagedKafka\V1\Client\ManagedKafkaConnectClient;
use Google\Cloud\ManagedKafka\V1\Connector;
use Google\Cloud\ManagedKafka\V1\CreateConnectorRequest;

/**
 * @param string $formattedParent The parent Connect cluster in which to create the connector.
 *                                Structured like
 *                                `projects/{project}/locations/{location}/connectClusters/{connect_cluster_id}`. Please see
 *                                {@see ManagedKafkaConnectClient::connectClusterName()} for help formatting this field.
 * @param string $connectorId     The ID to use for the connector, which will become the final
 *                                component of the connector's name. The ID must be 1-63 characters long, and
 *                                match the regular expression `[a-z]([-a-z0-9]*[a-z0-9])?` to comply with
 *                                RFC 1035.
 *
 *                                This value is structured like: `my-connector-id`.
 */
function create_connector_sample(string $formattedParent, string $connectorId): void
{
    // Create a client.
    $managedKafkaConnectClient = new ManagedKafkaConnectClient();

    // Prepare the request message.
    $connector = new Connector();
    $request = (new CreateConnectorRequest())
        ->setParent($formattedParent)
        ->setConnectorId($connectorId)
        ->setConnector($connector);

    // Call the API and handle any network failures.
    try {
        /** @var Connector $response */
        $response = $managedKafkaConnectClient->createConnector($request);
        printf('Response data: %s' . PHP_EOL, $response->serializeToJsonString());
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

/**
 * Helper to execute the sample.
 *
 * This sample has been automatically generated and should be regarded as a code
 * template only. It will require modifications to work:
 *  - It may require correct/in-range values for request initialization.
 *  - It may require specifying regional endpoints when creating the service client,
 *    please see the apiEndpoint client configuration option for more details.
 */
function callSample(): void
{
    $formattedParent = ManagedKafkaConnectClient::connectClusterName(
        '[PROJECT]',
        '[LOCATION]',
        '[CONNECT_CLUSTER]'
    );
    $connectorId = '[CONNECTOR_ID]';

    create_connector_sample($formattedParent, $connectorId);
}

use Google\ApiCore\ApiException;
use Google\ApiCore\OperationResponse;
use Google\Cloud\ManagedKafka\V1\Client\ManagedKafkaConnectClient;
use Google\Cloud\ManagedKafka\V1\DeleteConnectClusterRequest;
use Google\Rpc\Status;

/**
 * @param string $formattedName The name of the Kafka Connect cluster to delete.
 *                              Structured like
 *                              `projects/{project}/locations/{location}/connectClusters/{connect_cluster_id}`. Please see
 *                              {@see ManagedKafkaConnectClient::connectClusterName()} for help formatting this field.
 */
function delete_connect_cluster_sample(string $formattedName): void
{
    // Create a client.
    $managedKafkaConnectClient = new ManagedKafkaConnectClient();

    // Prepare the request message.
    $request = (new DeleteConnectClusterRequest())
        ->setName($formattedName);

    // Call the API and handle any network failures.
    try {
        /** @var OperationResponse $response */
        $response = $managedKafkaConnectClient->deleteConnectCluster($request);
        $response->pollUntilComplete();

        if ($response->operationSucceeded()) {
            printf('Operation completed successfully.' . PHP_EOL);
        } else {
            /** @var Status $error */
            $error = $response->getError();
            printf('Operation failed with error data: %s' . PHP_EOL, $error->serializeToJsonString());
        }
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

/**
 * Helper to execute the sample.
 *
 * This sample has been automatically generated and should be regarded as a code
 * template only. It will require modifications to work:
 *  - It may require correct/in-range values for request initialization.
 *  - It may require specifying regional endpoints when creating the service client,
 *    please see the apiEndpoint client configuration option for more details.
 */
function callSample(): void
{
    $formattedName = ManagedKafkaConnectClient::connectClusterName(
        '[PROJECT]',
        '[LOCATION]',
        '[CONNECT_CLUSTER]'
    );

    delete_connect_cluster_sample($formattedName);
}

use Google\ApiCore\ApiException;
use Google\Cloud\ManagedKafka\V1\Client\ManagedKafkaConnectClient;
use Google\Cloud\ManagedKafka\V1\DeleteConnectorRequest;

/**
 * @param string $formattedName The name of the connector to delete.
 *                              Structured like:
 *                              projects/{project}/locations/{location}/connectClusters/{connectCluster}/connectors/{connector}
 *                              Please see {@see ManagedKafkaConnectClient::connectorName()} for help formatting this field.
 */
function delete_connector_sample(string $formattedName): void
{
    // Create a client.
    $managedKafkaConnectClient = new ManagedKafkaConnectClient();

    // Prepare the request message.
    $request = (new DeleteConnectorRequest())
        ->setName($formattedName);

    // Call the API and handle any network failures.
    try {
        $managedKafkaConnectClient->deleteConnector($request);
        printf('Call completed successfully.' . PHP_EOL);
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

/**
 * Helper to execute the sample.
 *
 * This sample has been automatically generated and should be regarded as a code
 * template only. It will require modifications to work:
 *  - It may require correct/in-range values for request initialization.
 *  - It may require specifying regional endpoints when creating the service client,
 *    please see the apiEndpoint client configuration option for more details.
 */
function callSample(): void
{
    $formattedName = ManagedKafkaConnectClient::connectorName(
        '[PROJECT]',
        '[LOCATION]',
        '[CONNECT_CLUSTER]',
        '[CONNECTOR]'
    );

    delete_connector_sample($formattedName);
}

use Google\ApiCore\ApiException;
use Google\Cloud\ManagedKafka\V1\Client\ManagedKafkaConnectClient;
use Google\Cloud\ManagedKafka\V1\ConnectCluster;
use Google\Cloud\ManagedKafka\V1\GetConnectClusterRequest;

/**
 * @param string $formattedName The name of the Kafka Connect cluster whose configuration to
 *                              return. Structured like
 *                              `projects/{project}/locations/{location}/connectClusters/{connect_cluster_id}`. Please see
 *                              {@see ManagedKafkaConnectClient::connectClusterName()} for help formatting this field.
 */
function get_connect_cluster_sample(string $formattedName): void
{
    // Create a client.
    $managedKafkaConnectClient = new ManagedKafkaConnectClient();

    // Prepare the request message.
    $request = (new GetConnectClusterRequest())
        ->setName($formattedName);

    // Call the API and handle any network failures.
    try {
        /** @var ConnectCluster $response */
        $response = $managedKafkaConnectClient->getConnectCluster($request);
        printf('Response data: %s' . PHP_EOL, $response->serializeToJsonString());
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

/**
 * Helper to execute the sample.
 *
 * This sample has been automatically generated and should be regarded as a code
 * template only. It will require modifications to work:
 *  - It may require correct/in-range values for request initialization.
 *  - It may require specifying regional endpoints when creating the service client,
 *    please see the apiEndpoint client configuration option for more details.
 */
function callSample(): void
{
    $formattedName = ManagedKafkaConnectClient::connectClusterName(
        '[PROJECT]',
        '[LOCATION]',
        '[CONNECT_CLUSTER]'
    );

    get_connect_cluster_sample($formattedName);
}

use Google\ApiCore\ApiException;
use Google\Cloud\ManagedKafka\V1\Client\ManagedKafkaConnectClient;
use Google\Cloud\ManagedKafka\V1\Connector;
use Google\Cloud\ManagedKafka\V1\GetConnectorRequest;

/**
 * @param string $formattedName The name of the connector whose configuration to return.
 *                              Structured like:
 *                              projects/{project}/locations/{location}/connectClusters/{connectCluster}/connectors/{connector}
 *                              Please see {@see ManagedKafkaConnectClient::connectorName()} for help formatting this field.
 */
function get_connector_sample(string $formattedName): void
{
    // Create a client.
    $managedKafkaConnectClient = new ManagedKafkaConnectClient();

    // Prepare the request message.
    $request = (new GetConnectorRequest())
        ->setName($formattedName);

    // Call the API and handle any network failures.
    try {
        /** @var Connector $response */
        $response = $managedKafkaConnectClient->getConnector($request);
        printf('Response data: %s' . PHP_EOL, $response->serializeToJsonString());
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

/**
 * Helper to execute the sample.
 *
 * This sample has been automatically generated and should be regarded as a code
 * template only. It will require modifications to work:
 *  - It may require correct/in-range values for request initialization.
 *  - It may require specifying regional endpoints when creating the service client,
 *    please see the apiEndpoint client configuration option for more details.
 */
function callSample(): void
{
    $formattedName = ManagedKafkaConnectClient::connectorName(
        '[PROJECT]',
        '[LOCATION]',
        '[CONNECT_CLUSTER]',
        '[CONNECTOR]'
    );

    get_connector_sample($formattedName);
}

use Google\ApiCore\ApiException;
use Google\ApiCore\PagedListResponse;
use Google\Cloud\ManagedKafka\V1\Client\ManagedKafkaConnectClient;
use Google\Cloud\ManagedKafka\V1\ConnectCluster;
use Google\Cloud\ManagedKafka\V1\ListConnectClustersRequest;

/**
 * @param string $formattedParent The parent project/location whose Connect clusters are to be
 *                                listed. Structured like `projects/{project}/locations/{location}`. Please see
 *                                {@see ManagedKafkaConnectClient::locationName()} for help formatting this field.
 */
function list_connect_clusters_sample(string $formattedParent): void
{
    // Create a client.
    $managedKafkaConnectClient = new ManagedKafkaConnectClient();

    // Prepare the request message.
    $request = (new ListConnectClustersRequest())
        ->setParent($formattedParent);

    // Call the API and handle any network failures.
    try {
        /** @var PagedListResponse $response */
        $response = $managedKafkaConnectClient->listConnectClusters($request);

        /** @var ConnectCluster $element */
        foreach ($response as $element) {
            printf('Element data: %s' . PHP_EOL, $element->serializeToJsonString());
        }
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

/**
 * Helper to execute the sample.
 *
 * This sample has been automatically generated and should be regarded as a code
 * template only. It will require modifications to work:
 *  - It may require correct/in-range values for request initialization.
 *  - It may require specifying regional endpoints when creating the service client,
 *    please see the apiEndpoint client configuration option for more details.
 */
function callSample(): void
{
    $formattedParent = ManagedKafkaConnectClient::locationName('[PROJECT]', '[LOCATION]');

    list_connect_clusters_sample($formattedParent);
}

use Google\ApiCore\ApiException;
use Google\ApiCore\PagedListResponse;
use Google\Cloud\ManagedKafka\V1\Client\ManagedKafkaConnectClient;
use Google\Cloud\ManagedKafka\V1\Connector;
use Google\Cloud\ManagedKafka\V1\ListConnectorsRequest;

/**
 * @param string $formattedParent The parent Connect cluster whose connectors are to be listed.
 *                                Structured like
 *                                `projects/{project}/locations/{location}/connectClusters/{connect_cluster_id}`. Please see
 *                                {@see ManagedKafkaConnectClient::connectClusterName()} for help formatting this field.
 */
function list_connectors_sample(string $formattedParent): void
{
    // Create a client.
    $managedKafkaConnectClient = new ManagedKafkaConnectClient();

    // Prepare the request message.
    $request = (new ListConnectorsRequest())
        ->setParent($formattedParent);

    // Call the API and handle any network failures.
    try {
        /** @var PagedListResponse $response */
        $response = $managedKafkaConnectClient->listConnectors($request);

        /** @var Connector $element */
        foreach ($response as $element) {
            printf('Element data: %s' . PHP_EOL, $element->serializeToJsonString());
        }
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

/**
 * Helper to execute the sample.
 *
 * This sample has been automatically generated and should be regarded as a code
 * template only. It will require modifications to work:
 *  - It may require correct/in-range values for request initialization.
 *  - It may require specifying regional endpoints when creating the service client,
 *    please see the apiEndpoint client configuration option for more details.
 */
function callSample(): void
{
    $formattedParent = ManagedKafkaConnectClient::connectClusterName(
        '[PROJECT]',
        '[LOCATION]',
        '[CONNECT_CLUSTER]'
    );

    list_connectors_sample($formattedParent);
}

use Google\ApiCore\ApiException;
use Google\Cloud\ManagedKafka\V1\Client\ManagedKafkaConnectClient;
use Google\Cloud\ManagedKafka\V1\PauseConnectorRequest;
use Google\Cloud\ManagedKafka\V1\PauseConnectorResponse;

/**
 * @param string $formattedName The name of the connector to pause.
 *                              Structured like:
 *                              projects/{project}/locations/{location}/connectClusters/{connectCluster}/connectors/{connector}
 *                              Please see {@see ManagedKafkaConnectClient::connectorName()} for help formatting this field.
 */
function pause_connector_sample(string $formattedName): void
{
    // Create a client.
    $managedKafkaConnectClient = new ManagedKafkaConnectClient();

    // Prepare the request message.
    $request = (new PauseConnectorRequest())
        ->setName($formattedName);

    // Call the API and handle any network failures.
    try {
        /** @var PauseConnectorResponse $response */
        $response = $managedKafkaConnectClient->pauseConnector($request);
        printf('Response data: %s' . PHP_EOL, $response->serializeToJsonString());
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

/**
 * Helper to execute the sample.
 *
 * This sample has been automatically generated and should be regarded as a code
 * template only. It will require modifications to work:
 *  - It may require correct/in-range values for request initialization.
 *  - It may require specifying regional endpoints when creating the service client,
 *    please see the apiEndpoint client configuration option for more details.
 */
function callSample(): void
{
    $formattedName = ManagedKafkaConnectClient::connectorName(
        '[PROJECT]',
        '[LOCATION]',
        '[CONNECT_CLUSTER]',
        '[CONNECTOR]'
    );

    pause_connector_sample($formattedName);
}

use Google\ApiCore\ApiException;
use Google\Cloud\ManagedKafka\V1\Client\ManagedKafkaConnectClient;
use Google\Cloud\ManagedKafka\V1\RestartConnectorRequest;
use Google\Cloud\ManagedKafka\V1\RestartConnectorResponse;

/**
 * @param string $formattedName The name of the connector to restart.
 *                              Structured like:
 *                              projects/{project}/locations/{location}/connectClusters/{connectCluster}/connectors/{connector}
 *                              Please see {@see ManagedKafkaConnectClient::connectorName()} for help formatting this field.
 */
function restart_connector_sample(string $formattedName): void
{
    // Create a client.
    $managedKafkaConnectClient = new ManagedKafkaConnectClient();

    // Prepare the request message.
    $request = (new RestartConnectorRequest())
        ->setName($formattedName);

    // Call the API and handle any network failures.
    try {
        /** @var RestartConnectorResponse $response */
        $response = $managedKafkaConnectClient->restartConnector($request);
        printf('Response data: %s' . PHP_EOL, $response->serializeToJsonString());
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

/**
 * Helper to execute the sample.
 *
 * This sample has been automatically generated and should be regarded as a code
 * template only. It will require modifications to work:
 *  - It may require correct/in-range values for request initialization.
 *  - It may require specifying regional endpoints when creating the service client,
 *    please see the apiEndpoint client configuration option for more details.
 */
function callSample(): void
{
    $formattedName = ManagedKafkaConnectClient::connectorName(
        '[PROJECT]',
        '[LOCATION]',
        '[CONNECT_CLUSTER]',
        '[CONNECTOR]'
    );

    restart_connector_sample($formattedName);
}

use Google\ApiCore\ApiException;
use Google\Cloud\ManagedKafka\V1\Client\ManagedKafkaConnectClient;
use Google\Cloud\ManagedKafka\V1\ResumeConnectorRequest;
use Google\Cloud\ManagedKafka\V1\ResumeConnectorResponse;

/**
 * @param string $formattedName The name of the connector to pause.
 *                              Structured like:
 *                              projects/{project}/locations/{location}/connectClusters/{connectCluster}/connectors/{connector}
 *                              Please see {@see ManagedKafkaConnectClient::connectorName()} for help formatting this field.
 */
function resume_connector_sample(string $formattedName): void
{
    // Create a client.
    $managedKafkaConnectClient = new ManagedKafkaConnectClient();

    // Prepare the request message.
    $request = (new ResumeConnectorRequest())
        ->setName($formattedName);

    // Call the API and handle any network failures.
    try {
        /** @var ResumeConnectorResponse $response */
        $response = $managedKafkaConnectClient->resumeConnector($request);
        printf('Response data: %s' . PHP_EOL, $response->serializeToJsonString());
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

/**
 * Helper to execute the sample.
 *
 * This sample has been automatically generated and should be regarded as a code
 * template only. It will require modifications to work:
 *  - It may require correct/in-range values for request initialization.
 *  - It may require specifying regional endpoints when creating the service client,
 *    please see the apiEndpoint client configuration option for more details.
 */
function callSample(): void
{
    $formattedName = ManagedKafkaConnectClient::connectorName(
        '[PROJECT]',
        '[LOCATION]',
        '[CONNECT_CLUSTER]',
        '[CONNECTOR]'
    );

    resume_connector_sample($formattedName);
}

use Google\ApiCore\ApiException;
use Google\Cloud\ManagedKafka\V1\Client\ManagedKafkaConnectClient;
use Google\Cloud\ManagedKafka\V1\StopConnectorRequest;
use Google\Cloud\ManagedKafka\V1\StopConnectorResponse;

/**
 * @param string $formattedName The name of the connector to stop.
 *                              Structured like:
 *                              projects/{project}/locations/{location}/connectClusters/{connectCluster}/connectors/{connector}
 *                              Please see {@see ManagedKafkaConnectClient::connectorName()} for help formatting this field.
 */
function stop_connector_sample(string $formattedName): void
{
    // Create a client.
    $managedKafkaConnectClient = new ManagedKafkaConnectClient();

    // Prepare the request message.
    $request = (new StopConnectorRequest())
        ->setName($formattedName);

    // Call the API and handle any network failures.
    try {
        /** @var StopConnectorResponse $response */
        $response = $managedKafkaConnectClient->stopConnector($request);
        printf('Response data: %s' . PHP_EOL, $response->serializeToJsonString());
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

/**
 * Helper to execute the sample.
 *
 * This sample has been automatically generated and should be regarded as a code
 * template only. It will require modifications to work:
 *  - It may require correct/in-range values for request initialization.
 *  - It may require specifying regional endpoints when creating the service client,
 *    please see the apiEndpoint client configuration option for more details.
 */
function callSample(): void
{
    $formattedName = ManagedKafkaConnectClient::connectorName(
        '[PROJECT]',
        '[LOCATION]',
        '[CONNECT_CLUSTER]',
        '[CONNECTOR]'
    );

    stop_connector_sample($formattedName);
}

use Google\ApiCore\ApiException;
use Google\ApiCore\OperationResponse;
use Google\Cloud\ManagedKafka\V1\CapacityConfig;
use Google\Cloud\ManagedKafka\V1\Client\ManagedKafkaConnectClient;
use Google\Cloud\ManagedKafka\V1\ConnectAccessConfig;
use Google\Cloud\ManagedKafka\V1\ConnectCluster;
use Google\Cloud\ManagedKafka\V1\ConnectGcpConfig;
use Google\Cloud\ManagedKafka\V1\ConnectNetworkConfig;
use Google\Cloud\ManagedKafka\V1\UpdateConnectClusterRequest;
use Google\Protobuf\FieldMask;
use Google\Rpc\Status;

/**
 * @param string $connectClusterGcpConfigAccessConfigNetworkConfigsPrimarySubnet VPC subnet to make available to the Kafka Connect cluster.
 *                                                                               Structured like:
 *                                                                               projects/{project}/regions/{region}/subnetworks/{subnet_id}
 *
 *                                                                               It is used to create a Private Service Connect (PSC) interface for the
 *                                                                               Kafka Connect workers. It must be located in the same region as the
 *                                                                               Kafka Connect cluster.
 *
 *                                                                               The CIDR range of the subnet must be within the IPv4 address ranges for
 *                                                                               private networks, as specified in RFC 1918. The primary subnet CIDR range
 *                                                                               must have a minimum size of /22 (1024 addresses).
 * @param string $connectClusterKafkaCluster                                     Immutable. The name of the Kafka cluster this Kafka Connect
 *                                                                               cluster is attached to. Structured like:
 *                                                                               projects/{project}/locations/{location}/clusters/{cluster}
 * @param int    $connectClusterCapacityConfigVcpuCount                          The number of vCPUs to provision for the cluster. Minimum: 3.
 * @param int    $connectClusterCapacityConfigMemoryBytes                        The memory to provision for the cluster in bytes.
 *                                                                               The CPU:memory ratio (vCPU:GiB) must be between 1:1 and 1:8.
 *                                                                               Minimum: 3221225472 (3 GiB).
 */
function update_connect_cluster_sample(
    string $connectClusterGcpConfigAccessConfigNetworkConfigsPrimarySubnet,
    string $connectClusterKafkaCluster,
    int $connectClusterCapacityConfigVcpuCount,
    int $connectClusterCapacityConfigMemoryBytes
): void {
    // Create a client.
    $managedKafkaConnectClient = new ManagedKafkaConnectClient();

    // Prepare the request message.
    $updateMask = new FieldMask();
    $connectNetworkConfig = (new ConnectNetworkConfig())
        ->setPrimarySubnet($connectClusterGcpConfigAccessConfigNetworkConfigsPrimarySubnet);
    $connectClusterGcpConfigAccessConfigNetworkConfigs = [$connectNetworkConfig,];
    $connectClusterGcpConfigAccessConfig = (new ConnectAccessConfig())
        ->setNetworkConfigs($connectClusterGcpConfigAccessConfigNetworkConfigs);
    $connectClusterGcpConfig = (new ConnectGcpConfig())
        ->setAccessConfig($connectClusterGcpConfigAccessConfig);
    $connectClusterCapacityConfig = (new CapacityConfig())
        ->setVcpuCount($connectClusterCapacityConfigVcpuCount)
        ->setMemoryBytes($connectClusterCapacityConfigMemoryBytes);
    $connectCluster = (new ConnectCluster())
        ->setGcpConfig($connectClusterGcpConfig)
        ->setKafkaCluster($connectClusterKafkaCluster)
        ->setCapacityConfig($connectClusterCapacityConfig);
    $request = (new UpdateConnectClusterRequest())
        ->setUpdateMask($updateMask)
        ->setConnectCluster($connectCluster);

    // Call the API and handle any network failures.
    try {
        /** @var OperationResponse $response */
        $response = $managedKafkaConnectClient->updateConnectCluster($request);
        $response->pollUntilComplete();

        if ($response->operationSucceeded()) {
            /** @var ConnectCluster $result */
            $result = $response->getResult();
            printf('Operation successful with response data: %s' . PHP_EOL, $result->serializeToJsonString());
        } else {
            /** @var Status $error */
            $error = $response->getError();
            printf('Operation failed with error data: %s' . PHP_EOL, $error->serializeToJsonString());
        }
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

/**
 * Helper to execute the sample.
 *
 * This sample has been automatically generated and should be regarded as a code
 * template only. It will require modifications to work:
 *  - It may require correct/in-range values for request initialization.
 *  - It may require specifying regional endpoints when creating the service client,
 *    please see the apiEndpoint client configuration option for more details.
 */
function callSample(): void
{
    $connectClusterGcpConfigAccessConfigNetworkConfigsPrimarySubnet = '[PRIMARY_SUBNET]';
    $connectClusterKafkaCluster = '[KAFKA_CLUSTER]';
    $connectClusterCapacityConfigVcpuCount = 0;
    $connectClusterCapacityConfigMemoryBytes = 0;

    update_connect_cluster_sample(
        $connectClusterGcpConfigAccessConfigNetworkConfigsPrimarySubnet,
        $connectClusterKafkaCluster,
        $connectClusterCapacityConfigVcpuCount,
        $connectClusterCapacityConfigMemoryBytes
    );
}

use Google\ApiCore\ApiException;
use Google\Cloud\ManagedKafka\V1\Client\ManagedKafkaConnectClient;
use Google\Cloud\ManagedKafka\V1\Connector;
use Google\Cloud\ManagedKafka\V1\UpdateConnectorRequest;
use Google\Protobuf\FieldMask;

/**
 * This sample has been automatically generated and should be regarded as a code
 * template only. It will require modifications to work:
 *  - It may require correct/in-range values for request initialization.
 *  - It may require specifying regional endpoints when creating the service client,
 *    please see the apiEndpoint client configuration option for more details.
 */
function update_connector_sample(): void
{
    // Create a client.
    $managedKafkaConnectClient = new ManagedKafkaConnectClient();

    // Prepare the request message.
    $updateMask = new FieldMask();
    $connector = new Connector();
    $request = (new UpdateConnectorRequest())
        ->setUpdateMask($updateMask)
        ->setConnector($connector);

    // Call the API and handle any network failures.
    try {
        /** @var Connector $response */
        $response = $managedKafkaConnectClient->updateConnector($request);
        printf('Response data: %s' . PHP_EOL, $response->serializeToJsonString());
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

use Google\ApiCore\ApiException;
use Google\Cloud\Location\GetLocationRequest;
use Google\Cloud\Location\Location;
use Google\Cloud\ManagedKafka\V1\Client\ManagedKafkaConnectClient;

/**
 * This sample has been automatically generated and should be regarded as a code
 * template only. It will require modifications to work:
 *  - It may require correct/in-range values for request initialization.
 *  - It may require specifying regional endpoints when creating the service client,
 *    please see the apiEndpoint client configuration option for more details.
 */
function get_location_sample(): void
{
    // Create a client.
    $managedKafkaConnectClient = new ManagedKafkaConnectClient();

    // Prepare the request message.
    $request = new GetLocationRequest();

    // Call the API and handle any network failures.
    try {
        /** @var Location $response */
        $response = $managedKafkaConnectClient->getLocation($request);
        printf('Response data: %s' . PHP_EOL, $response->serializeToJsonString());
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}

use Google\ApiCore\ApiException;
use Google\ApiCore\PagedListResponse;
use Google\Cloud\Location\ListLocationsRequest;
use Google\Cloud\Location\Location;
use Google\Cloud\ManagedKafka\V1\Client\ManagedKafkaConnectClient;

/**
 * This sample has been automatically generated and should be regarded as a code
 * template only. It will require modifications to work:
 *  - It may require correct/in-range values for request initialization.
 *  - It may require specifying regional endpoints when creating the service client,
 *    please see the apiEndpoint client configuration option for more details.
 */
function list_locations_sample(): void
{
    // Create a client.
    $managedKafkaConnectClient = new ManagedKafkaConnectClient();

    // Prepare the request message.
    $request = new ListLocationsRequest();

    // Call the API and handle any network failures.
    try {
        /** @var PagedListResponse $response */
        $response = $managedKafkaConnectClient->listLocations($request);

        /** @var Location $element */
        foreach ($response as $element) {
            printf('Element data: %s' . PHP_EOL, $element->serializeToJsonString());
        }
    } catch (ApiException $ex) {
        printf('Call failed with message: %s' . PHP_EOL, $ex->getMessage());
    }
}