O Google usa tecnologia de IA na tradução de conteúdos para seu idioma de preferência. As traduções com IA podem ter erros.

Listar seus clusters do Connect

Listar os clusters do Connect permite visualizar os detalhes de todos os clusters do Connect em um único painel, incluindo detalhes como integridade, locais, tempo de atividade, tamanho de computação, cluster do Serviço Gerenciado do Google Cloud para Apache Kafka associado e rótulos.

Para listar os clusters do Connect, use o Google Cloud console, a CLI gcloud, a biblioteca de cliente ou a API Managed Kafka. Não é possível usar a API do Apache Kafka de código aberto para listar clusters do Connect.

Papéis e permissões necessários para listar os clusters do Connect

Para ter as permissões necessárias para listar os clusters do Connect, peça ao administrador para conceder a você o papel do IAM de leitor do Managed Kafka (roles/managedkafka.viewer) no seu projeto. Para mais informações sobre a concessão de papéis, consulte Gerenciar o acesso a projetos, pastas e organizações.

Esse papel predefinido contém as permissões necessárias para listar os clusters do Connect. Para acessar as permissões exatas que são necessárias, expanda a seção Permissões necessárias:

Permissões necessárias

As permissões a seguir são necessárias para listar os clusters do Connect:

Conceda a permissão de listar clusters no local especificado: managedkafka.connectClusters.list
Conceda a permissão de receber detalhes do cluster no local especificado: managedkafka.connectClusters.get

Essas permissões também podem ser concedidas com funções personalizadas ou outros papéis predefinidos.

Conferir os clusters do Connect

Console

Noconsole, acesse a página Clusters do Connect. Google Cloud

Acessar clusters do Connect
Os clusters criados em um projeto são listados. A página permite visualizar as seguintes propriedades do cluster:
- Nome: o identificador exclusivo do cluster do Connect. É possível usá-lo para referenciar o cluster do Connect em várias operações.
- Estado: indica o status operacional atual do cluster do Connect, como Ativo.
- Local: o local geográfico em que o cluster do Connect está hospedado.
- Hora da atualização: a hora em que o cluster do Connect foi atualizado pela última vez.
- vCPUs: o número de vCPUs atribuídas ao cluster do Connect.
- Memória: a quantidade total de memória alocada para o cluster do Connect.
- Cluster principal do Kafka: o cluster do Serviço Gerenciado para Apache Kafka associado ao cluster do Connect.
- Rótulos: pares de chave-valor que podem ser anexados ao cluster do Connect para fins de organização, filtragem e automação.

gcloud

No Google Cloud console, ative o Cloud Shell.

Ativar o Cloud Shell

Na parte de baixo do Google Cloud console, uma sessão do Cloud Shell é iniciada e exibe um prompt de linha de comando. O Cloud Shell é um ambiente shell com a Google Cloud CLI já instalada e com valores já definidos para o projeto atual. A inicialização da sessão pode levar alguns segundos.
Use o gcloud managed-kafka connect-clusters list comando para listar os clusters do Connect:
```
gcloud managed-kafka connect-clusters list \
    --location=LOCATION
```
Para refinar ainda mais a lista de clusters do Connect, use outras flags:
```
gcloud managed-kafka connect-clusters list \
    --location=LOCATION \
    [--filter=EXPRESSION] \
    [--limit=LIMIT] \
    [--page-size=PAGE_SIZE] \
    [--sort-by=SORT_BY]
```
Substitua:
- LOCATION: obrigatório. O local dos clusters do Connect que você quer listar.
- EXPRESSION: (opcional) uma expressão de filtro booleana a ser aplicada à lista. Se a expressão for avaliada como True, o item será incluído na lista. Para mais detalhes e exemplos, execute gcloud topic filters.
- LIMIT: (opcional) o número máximo de clusters do Connect a serem exibidos. Se não for especificado, todos os clusters do Connect serão listados.
- PAGE_SIZE: (opcional) o número de resultados a serem exibidos por página. Se não for especificado, o serviço determinará um tamanho de página adequado.
- SORT_BY: (Opcional) Uma lista separada por vírgulas de campos para classificar. A ordem de classificação padrão é crescente. Para classificar em ordem decrescente, inclua o prefixo ~ no campo.

Exemplo de saída:

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

Go

Antes de testar esta amostra, siga as instruções de configuração para Go em Instalar as bibliotecas de cliente. Para mais informações, consulte a documentação de referência da API Serviço Gerenciado para Apache Kafka Go.

Para autenticar o Serviço Gerenciado para Apache Kafka, configure o Application Default Credentials(ADC). Para mais informações, consulte Configurar o ADC para um ambiente de desenvolvimento 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 testar esta amostra, siga as instruções de configuração para Java em Instalar as bibliotecas de cliente. Para mais informações, consulte a documentação de referência da API do Serviço Gerenciado para Apache Kafka Java.

Para autenticar o Serviço Gerenciado para Apache Kafka, configure o Application Default Credentials. Para mais informações, consulte Configurar o ADC para um ambiente de desenvolvimento 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 testar esta amostra, siga as instruções de configuração para Python em Instalar as bibliotecas de cliente. Para mais informações, consulte a documentação de referência da API Managed Service for Apache Kafka Python.