Enumera tus clústeres de Connect

En la lista de tus clústeres de Connect, puedes ver los detalles de todos tus clústeres de Connect en un solo panel, incluidos detalles como el estado de los clústeres, las ubicaciones, el tiempo de actividad de los clústeres, el tamaño de procesamiento, el clúster asociado de Servicio administrado de Google Cloud para Apache Kafka y las etiquetas.

Para enumerar tus clústeres de Connect, puedes usar la consola de Google Cloud , gcloud CLI, la biblioteca cliente o la API de Kafka administrado. No puedes usar la API de Apache Kafka de código abierto para enumerar clústeres de Connect.

Roles y permisos obligatorios para enumerar tus clústeres de Connect

Para obtener los permisos que necesitas para enumerar tus clústeres de Connect, pídele a tu administrador que te otorgue el rol de IAM Visualizador de Kafka administrado (roles/managedkafka.viewer) en tu proyecto. Para obtener más información sobre cómo otorgar roles, consulta Administra el acceso a proyectos, carpetas y organizaciones.

Este rol predefinido contiene los permisos necesarios para enumerar tus clústeres de Connect. Para ver los permisos exactos que son necesarios, expande la sección Permisos requeridos:

Permisos necesarios

Se requieren los siguientes permisos para enumerar tus clústeres de Connect:

Otorga el permiso para enumerar clústeres en la ubicación especificada: managedkafka.connectClusters.list
Otorga el permiso para obtener detalles del clúster en la ubicación especificada: managedkafka.connectClusters.get

También puedes obtener estos permisos con roles personalizados o con otros roles predefinidos.

Para obtener más información sobre el rol de visualizador de Kafka administrado, consulta Roles predefinidos de Managed Service para Apache Kafka.

Visualiza tus clústeres de Connect

Console

En la consola de Google Cloud , ve a la página Connect Clusters.

Ir a Connect Clusters
Se muestran los clústeres que creaste en un proyecto. En la página, puedes ver las siguientes propiedades del clúster:
- Nombre: Es el identificador único de tu clúster de Connect. Puedes usarlo para hacer referencia al clúster de Connect en varias operaciones.
- Estado: Indica el estado operativo actual del clúster de Connect, como Activo.
- Ubicación: Es la ubicación geográfica en la que se aloja tu clúster de Connect.
- Hora de actualización: Es la fecha y hora en que se actualizó el clúster de Connect por última vez.
- vCPUs: Es la cantidad de CPU virtuales asignadas al clúster de Connect.
- Memoria: Es la cantidad total de memoria asignada al clúster de Connect.
- Clúster principal de Kafka: Es el clúster de Managed Service para Apache Kafka asociado con el clúster de Connect.
- Etiquetas: Son pares clave-valor que puedes adjuntar al clúster de Connect para fines de organización, filtrado y automatización.

gcloud

In the Google Cloud console, activate Cloud Shell.

Activate Cloud Shell

At the bottom of the Google Cloud console, a Cloud Shell session starts and displays a command-line prompt. Cloud Shell is a shell environment with the Google Cloud CLI already installed and with values already set for your current project. It can take a few seconds for the session to initialize.
Usa el comando gcloud managed-kafka connect-clusters list para enumerar los clústeres de Connect:
```
gcloud managed-kafka connect-clusters list \
    --location=LOCATION
```
Para definir mejor la lista de clústeres de Connect, puedes usar marcas adicionales:
```
gcloud managed-kafka connect-clusters list \
    --location=LOCATION \
    [--filter=EXPRESSION] \
    [--limit=LIMIT] \
    [--page-size=PAGE_SIZE] \
    [--sort-by=SORT_BY]
```
Reemplaza lo siguiente:
- LOCATION: Obligatorio. Es la ubicación de los clústeres de Connect que deseas enumerar.
- EXPRESSION: (Opcional) Es una expresión de filtro booleano que se aplicará a la lista. Si la expresión se evalúa como True, el elemento se incluye en la lista. Para obtener más detalles y ejemplos, ejecuta gcloud topic filters.
- LIMIT: (Opcional) Es la cantidad máxima de clústeres de Connect que se mostrarán. Si no se especifica, se mostrarán todos los clústeres de Connect.
- PAGE_SIZE: (Opcional) Es la cantidad de resultados que se mostrarán por página. Si no se especifica, el servicio determina un tamaño de página adecuado.
- SORT_BY: (Opcional) Es una lista de campos separados por comas según los cuales se ordenará la respuesta. El orden de clasificación predeterminado es ascendente. Para ordenar en orden descendente, agrega el prefijo ~ al campo.

Resultado de ejemplo:

NAME                   VCPU  MEMORY_BYTES  STATE   NETWORK
connect-cluster-alpha  3     3221225472    ACTIVE
connect-cluster-beta   3     3221225472    ACTIVE

Go

Antes de probar este ejemplo, sigue las instrucciones de configuración de Go en Instala las bibliotecas cliente. Para obtener más información, consulta la documentación de referencia de la API de Managed Service para Apache Kafka en Go.

Para autenticarte en Managed Service for Apache Kafka, configura las credenciales predeterminadas de la aplicación(ADC). Para obtener más información, consulta Configura ADC para un entorno de desarrollo local.

import (
	"context"
	"fmt"
	"io"

	"cloud.google.com/go/managedkafka/apiv1/managedkafkapb"
	"google.golang.org/api/iterator"
	"google.golang.org/api/option"

	managedkafka "cloud.google.com/go/managedkafka/apiv1"
)

func listConnectClusters(w io.Writer, projectID, region string, opts ...option.ClientOption) error {
	// projectID := "my-project-id"
	// region := "us-central1"
	ctx := context.Background()
	client, err := managedkafka.NewManagedKafkaConnectClient(ctx, opts...)
	if err != nil {
		return fmt.Errorf("managedkafka.NewManagedKafkaConnectClient got err: %w", err)
	}
	defer client.Close()

	locationPath := fmt.Sprintf("projects/%s/locations/%s", projectID, region)
	req := &managedkafkapb.ListConnectClustersRequest{
		Parent: locationPath,
	}
	clusterIter := client.ListConnectClusters(ctx, req)
	for {
		res, err := clusterIter.Next()
		if err == iterator.Done {
			break
		}
		if err != nil {
			return fmt.Errorf("clusterIter.Next() got err: %w", err)
		}
		fmt.Fprintf(w, "Got connect cluster: %v", res)
	}
	return nil
}

Java

Antes de probar este ejemplo, sigue las instrucciones de configuración de Java en Instala las bibliotecas cliente. Para obtener más información, consulta la documentación de referencia de la API de Java de Managed Service for Apache Kafka.

Para autenticarte en el servicio administrado para Apache Kafka, configura las credenciales predeterminadas de la aplicación. Para obtener más información, consulta Configura ADC para un entorno de desarrollo local.

import com.google.api.gax.rpc.ApiException;
import com.google.cloud.managedkafka.v1.ConnectCluster;
import com.google.cloud.managedkafka.v1.LocationName;
import com.google.cloud.managedkafka.v1.ManagedKafkaConnectClient;
import java.io.IOException;

public class ListConnectClusters {

  public static void main(String[] args) throws Exception {
    // TODO(developer): Replace these variables before running the example.
    String projectId = "my-project-id";
    String region = "my-region"; // e.g. us-east1
    listConnectClusters(projectId, region);
  }

  public static void listConnectClusters(String projectId, String region) throws Exception {
    try (ManagedKafkaConnectClient managedKafkaConnectClient = 
        ManagedKafkaConnectClient.create()) {
      LocationName locationName = LocationName.of(projectId, region);
      // This operation is being handled synchronously.
      for (ConnectCluster connectCluster : managedKafkaConnectClient
          .listConnectClusters(locationName).iterateAll()) {
        System.out.println(connectCluster.getAllFields());
      }
    } catch (IOException | ApiException e) {
      System.err.printf("managedKafkaConnectClient.listConnectClusters got err: %s\n", 
          e.getMessage());
    }
  }
}

Python

Antes de probar este ejemplo, sigue las instrucciones de configuración de Python en Instala las bibliotecas cliente. Si deseas obtener más información, consulta la documentación de referencia de la API de Python de Managed Service for Apache Kafka.

from google.cloud import managedkafka_v1
from google.cloud.managedkafka_v1.services.managed_kafka_connect import (
    ManagedKafkaConnectClient,
)
from google.api_core.exceptions import GoogleAPICallError

# TODO(developer)
# project_id = "my-project-id"
# region = "us-central1"

connect_client = ManagedKafkaConnectClient()

request = managedkafka_v1.ListConnectClustersRequest(
    parent=connect_client.common_location_path(project_id, region),
)

response = connect_client.list_connect_clusters(request=request)
for cluster in response:
    try:
        print("Got Connect cluster:", cluster)
    except GoogleAPICallError as e:
        print(f"Failed to list Connect clusters with error: {e}")

Próximos pasos

Apache Kafka® es una marca registrada de The Apache Software Foundation o sus afiliados en Estados Unidos y otros países.

Enumera tus clústeres de Connect Organiza tus páginas con colecciones Guarda y categoriza el contenido según tus preferencias.