Visualizzare un cluster Google Cloud Managed Service per Apache Kafka

Per visualizzare un cluster, puoi utilizzare la Google Cloud console, Google Cloud CLI, la libreria client o l'API Managed Kafka. Non puoi utilizzare l'API Apache Kafka open source per visualizzare un cluster.

Ruoli e autorizzazioni richiesti per visualizzare un cluster

Per ottenere le autorizzazioni necessarie per visualizzare un cluster, chiedi all'amministratore di concederti il ruolo IAM Visualizzatore di Managed Kafka (roles/managedkafka.viewer) nel progetto. Per saperne di più sulla concessione dei ruoli, consulta Gestisci l'accesso a progetti, cartelle e organizzazioni.

Questo ruolo predefinito contiene le autorizzazioni necessarie per visualizzare un cluster. Per vedere quali sono esattamente le autorizzazioni richieste, espandi la sezione Autorizzazioni obbligatorie:

Autorizzazioni obbligatorie

Per visualizzare un cluster sono necessarie le seguenti autorizzazioni:

  • Elenco dei cluster: managedkafka.clusters.list
  • Recupero dei dettagli del cluster: managedkafka.clusters.get

Potresti anche ottenere queste autorizzazioni con ruoli personalizzati o altri ruoli predefiniti.

Per saperne di più sul ruolo Visualizzatore di Managed Kafka, consulta Ruoli predefiniti di Managed Service per Apache Kafka.

Visualizzare un cluster

Per visualizzare un cluster:

Console

  1. Nella Google Cloud console, vai alla pagina Cluster.

    Vai a Cluster

    Vengono elencati i cluster creati in un progetto.

  2. Per visualizzare un cluster specifico, fai clic sul nome del cluster.

  3. Viene visualizzata la pagina dei dettagli del cluster. Questa pagina ha le seguenti schede:

    • Risorse: mostra l'elenco degli argomenti e dei gruppi di consumer associati al cluster.
    • Configurazioni: mostra la configurazione del cluster, incluso l'elenco delle subnet associate al cluster.
    • Monitoraggio: mostra gli avvisi di monitoraggio associati al cluster.
    • Log: mostra i log relativi ai cluster di Esplora log.

gcloud

  1. Nella Google Cloud console, attiva Cloud Shell.

    Attiva Cloud Shell

    Nella parte inferiore della Google Cloud console viene avviata una sessione di Cloud Shell e viene visualizzato un prompt della riga di comando. Cloud Shell è un ambiente shell con Google Cloud CLI già inclusa e installata e con valori già impostati per il progetto corrente. L'inizializzazione della sessione può richiedere alcuni secondi.

  2. Esegui il gcloud managed-kafka clusters describe comando:

    gcloud managed-kafka clusters describe CLUSTER_ID \
    --location=LOCATION \
    --full

    Sostituisci quanto segue:

    • CLUSTER_ID: l'ID o il nome del cluster.
    • LOCATION: la località del cluster.

    Il flag --full è facoltativo. Se includi questo flag, il comando restituisce informazioni aggiuntive, incluse informazioni sugli intermediari del cluster's brokers e sul numero di versione di Kafka in esecuzione nel cluster.

REST

Prima di utilizzare i dati della richiesta, apporta le sostituzioni seguenti:

  • PROJECT_ID: l'ID del tuo Google Cloud progetto
  • LOCATION: la località del cluster
  • CLUSTER_ID: l'ID del cluster

  • CLUSTER_VIEW: la quantità di metadati da restituire. Specifica uno dei seguenti valori:

    • CLUSTER_VIEW_BASIC: restituisce i metadati di base per il cluster.
    • CLUSTER_VIEW_FULL: restituisce tutti i metadati per il cluster, incluse informazioni sugli intermediari del cluster e sul numero di versione di Kafka in esecuzione nel cluster.

    Se non specificato, il metodo utilizza per impostazione predefinita CLUSTER_VIEW_BASIC.

Metodo HTTP e URL: 

GET https://managedkafka.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/clusters/CLUSTER_ID?view=CLUSTER_VIEW

Per inviare la richiesta, espandi una di queste opzioni:

Dovresti ricevere una risposta JSON simile alla seguente:

{
  "name": "projects/PROJECT_ID/locations/LOCATION/clusters/CLUSTER_ID",
  "createTime": "CREATE_TIME",
  "updateTime": "UPDATE_TIME",
  "capacityConfig": {
    "vcpuCount": "CPU_COUNT",
    "memoryBytes": "MEMORY"
  },
  "rebalanceConfig": {},
  "gcpConfig": {
    "accessConfig": {
      "networkConfigs": [
        {
          "subnet": "projects/PROJECT_ID/locations/LOCATION/subnetworks/SUBNET_ID"
        }
      ]
    }
  },
  "state": "ACTIVE",
  "satisfiesPzi": false,
  "satisfiesPzs": false,
  "tlsConfig": {
    "trustConfig": {}
  },
  "updateOptions": {}
}

Vai

Prima di provare questo esempio, segui le istruzioni di configurazione di Go in Installare le librerie client. Per saperne di più, consulta la documentazione di riferimento dell'API Go di Managed Service per Apache Kafka.

Per eseguire l'autenticazione a Managed Service per Apache Kafka, configura le credenziali predefinite dell'applicazione(ADC). Per saperne di più, consulta Configura ADC per un ambiente di sviluppo locale.

import (
	"context"
	"fmt"
	"io"

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

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

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

	clusterPath := fmt.Sprintf("projects/%s/locations/%s/clusters/%s", projectID, region, clusterID)
	req := &managedkafkapb.GetClusterRequest{
		Name: clusterPath,
	}
	cluster, err := client.GetCluster(ctx, req)
	if err != nil {
		return fmt.Errorf("client.GetCluster got err: %w", err)
	}
	fmt.Fprintf(w, "Got cluster: %#v\n", cluster)
	return nil
}

Java

Prima di provare questo esempio, segui le istruzioni di configurazione di Java in Installare le librerie client. Per saperne di più, consulta la documentazione di riferimento dell'API Java di Managed Service per Apache Kafka.

Per eseguire l'autenticazione a Managed Service per Apache Kafka, configura le credenziali predefinite dell'applicazione. Per saperne di più, consulta Configura ADC per un ambiente di sviluppo locale.

import com.google.api.gax.rpc.ApiException;
import com.google.cloud.managedkafka.v1.Cluster;
import com.google.cloud.managedkafka.v1.ClusterName;
import com.google.cloud.managedkafka.v1.ManagedKafkaClient;
import java.io.IOException;

public class GetCluster {

  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
    String clusterId = "my-cluster";
    getCluster(projectId, region, clusterId);
  }

  public static void getCluster(String projectId, String region, String clusterId)
      throws Exception {
    try (ManagedKafkaClient managedKafkaClient = ManagedKafkaClient.create()) {
      // This operation is being handled synchronously.
      Cluster cluster = managedKafkaClient.getCluster(ClusterName.of(projectId, region, clusterId));
      System.out.println(cluster.getAllFields());
    } catch (IOException | ApiException e) {
      System.err.printf("managedKafkaClient.getCluster got err: %s", e.getMessage());
    }
  }
}

Python

Prima di provare questo esempio, segui le istruzioni di configurazione di Python in Installare le librerie client. Per saperne di più, consulta la documentazione di riferimento dell'API Python di Managed Service per Apache Kafka.

Per eseguire l'autenticazione a Managed Service per Apache Kafka, configura le credenziali predefinite dell'applicazione. Per saperne di più, consulta Configura ADC per un ambiente di sviluppo locale.

from google.api_core.exceptions import NotFound
from google.cloud import managedkafka_v1

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

client = managedkafka_v1.ManagedKafkaClient()

cluster_path = client.cluster_path(project_id, region, cluster_id)
request = managedkafka_v1.GetClusterRequest(
    name=cluster_path,
)

try:
    cluster = client.get_cluster(request=request)
    print("Got cluster:", cluster)
except NotFound as e:
    print(f"Failed to get cluster {cluster_id} with error: {e.message}")

Visualizzare le proprietà e le risorse del cluster

Le seguenti sezioni descrivono come ottenere i dettagli di varie proprietà e risorse associate a un cluster Managed Service per Apache Kafka.

Indirizzo di bootstrap

I client Kafka utilizzano l'indirizzo di bootstrap del cluster per stabilire una connessione con il cluster. Per ottenere l'indirizzo di bootstrap:

Console

  1. Vai alla pagina Managed Service per Apache Kafka > Cluster.

    Vai a Cluster

  2. Fai clic sul nome del cluster.

  3. Seleziona la scheda Configurazioni.

  4. Se utilizzi SASL per l'autenticazione, l'URL di bootstrap è elencato in URL di bootstrap mTLS.

    Se utilizzi mutual TLS (mTLS) per l'autenticazione, l'URL di bootstrap è elencato in URL di bootstrap mTLS.

    Fai clic su Copia per copiare il valore.

gcloud

Per ottenere l'URL di bootstrap, utilizza il managed-kafka clusters describe comando.

Se utilizzi SASL per l'autenticazione, esegui il seguente comando:

gcloud managed-kafka clusters describe CLUSTER_ID \
  --location=LOCATION \
  --format="value(bootstrapAddress)"

Se utilizzi mutual TLS (mTLS) per l'autenticazione, esegui il seguente comando:

gcloud managed-kafka clusters describe CLUSTER_ID \
  --location=LOCATION \
  --format="value(bootstrapAddressMTLS)"

Sostituisci quanto segue:

  • CLUSTER_ID: l'ID o il nome del cluster.
  • LOCATION: la località del cluster.

Per saperne di più sull'autenticazione SASL e mTSL, consulta Tipi di autenticazione per gli intermediari Kafka.

Intermediari

Per visualizzare gli intermediari nel cluster, consulta Visualizzare gli intermediari in un cluster Managed Service per Apache Kafka.

Gruppi di consumer

Un gruppo di consumer è un insieme di consumer che collaborano per utilizzare i dati di vari argomenti. Per visualizzare i gruppi di consumer per un cluster, consulta le seguenti pagine:

Subnet

Per visualizzare le subnet connesse al cluster:

Console

  1. Nella Google Cloud console, vai alla pagina Cluster.

    Vai a Cluster

  2. Fai clic sul nome del cluster.

  3. Nella pagina dei dettagli del cluster, fai clic sulla scheda Configurazioni. Le subnet connesse sono elencate in Subnet.

gcloud

  1. Esegui il gcloud managed-kafka clusters describe comando:

    gcloud managed-kafka clusters describe CLUSTER_ID \
    --location=LOCATION \
    --format="yaml(gcpConfig.accessConfig.networkConfigs)"

    Sostituisci quanto segue:

    • CLUSTER_ID: l'ID o il nome del cluster.
    • LOCATION: la località del cluster.

Per saperne di più, consulta Configurare la rete per Managed Service per Apache Kafka.

Argomenti

Per visualizzare gli argomenti in un cluster, consulta le seguenti pagine:

Passaggi successivi

Apache Kafka® è un marchio registrato di The Apache Software Foundation o delle sue affiliate negli Stati Uniti e/o in altri paesi.