Per visualizzare un cluster, puoi utilizzare la console Google Cloud , 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 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 -
Recupera i dettagli del cluster:
managedkafka.clusters.get
Potresti anche ottenere queste autorizzazioni con ruoli personalizzati o altri ruoli predefiniti.
Visualizzare un cluster
Per visualizzare un cluster:
Console
Nella console Google Cloud , vai alla pagina Cluster.
Viene visualizzato l'elenco dei cluster che hai creato in un progetto.
Per visualizzare un cluster specifico, fai clic sul nome del cluster.
Viene visualizzata la pagina dei dettagli del cluster. Questa pagina contiene le seguenti schede:
- Risorse: mostra l'elenco di argomenti e gruppi di consumatori associati al cluster.
- Controllo dell'accesso: mostra le voci ACL per il 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.
- Origini: fornisce scorciatoie per creare connettori di origine Kafka Connect o generare dati di test sintetici.
- Sink: fornisce scorciatoie per la creazione di connettori sink Kafka Connect.
gcloud
-
Nella console Google Cloud , attiva Cloud Shell.
Nella parte inferiore della console Google Cloud 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à installata e con valori già impostati per il progetto corrente. L'inizializzazione della sessione può richiedere alcuni secondi.
Prima di utilizzare i dati dei comandi riportati di seguito, effettua le seguenti sostituzioni:
-
PROJECT_ID: l'ID progetto -
LOCATION: la posizione del cluster. -
CLUSTER_ID: l'ID del cluster.
Esegui questo comando:
Linux, macOS o Cloud Shell
gcloud managed-kafka clusters describe CLUSTER_ID \ --location=LOCATION \ --project=PROJECT_ID
Windows (PowerShell)
gcloud managed-kafka clusters describe CLUSTER_ID ` --location=LOCATION ` --project=PROJECT_ID
Windows (cmd.exe)
gcloud managed-kafka clusters describe CLUSTER_ID ^ --location=LOCATION ^ --project=PROJECT_ID
Dovresti ricevere una risposta simile alla seguente:
bootstrapAddress: bootstrap.CLUSTER_ID.LOCATION.managedkafka.PROJECT_ID.cloud.goog:9092 bootstrapAddressMTLS: bootstrap.CLUSTER_ID.LOCATION.managedkafka.PROJECT_ID.cloud.goog:9192 brokerCapacityConfig: {} capacityConfig: memoryBytes: 'MEMORY' vcpuCount: 'CPU_COUNT' createTime: 'CREATE_TIME' gcpConfig: accessConfig: networkConfigs: - subnet: projects/PROJECT_ID/regions/LOCATION/subnetworks/SUBNET_ID publicClusterConfig: allowedSourceIpRanges: - 203.0.113.5/32 labels: goog-terraform-provisioned: 'true' name: projects/PROJECT_ID/locations/LOCATION/clusters/CLUSTER_ID publicClusterDetails: discoveryDnsRecords: - discovery-1.CLUSTER_ID.LOCATION.managedkafka.PROJECT_ID.cloud.goog externalIpAddresses: - 203.0.113.1 - 203.0.113.2 - 203.0.113.3 - 203.0.113.4 rebalanceConfig: mode: AUTO_REBALANCE_ON_SCALE_UP satisfiesPzi: false satisfiesPzs: false state: ACTIVE tlsConfig: trustConfig: {} updateOptions: {} updateTime: 'UPDATE_TIME'-
REST
Prima di utilizzare i dati della richiesta, apporta le sostituzioni seguenti:
-
PROJECT_ID: il tuo Google Cloud ID progetto -
LOCATION: la posizione 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 del cluster, incluse le informazioni sui broker del cluster e il numero di versione di Kafka in esecuzione nel cluster.
Se non specificato, il metodo predefinito è
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"
}
],
"publicClusterConfig": {
"allowedSourceIpRanges": [
"203.0.113.5/32"
]
}
}
},
"state": "ACTIVE",
"satisfiesPzi": false,
"satisfiesPzs": false,
"tlsConfig": {
"trustConfig": {}
},
"updateOptions": {},
"publicClusterDetails": {
"discoveryDnsRecords": [
"discovery-1.CLUSTER_ID.LOCATION.managedkafka.PROJECT_ID.cloud.goog"
],
"externalIpAddresses": [
"203.0.113.1",
"203.0.113.2",
"203.0.113.3",
"203.0.113.4"
]
}
}
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 in Managed Service per Apache Kafka, configura le Credenziali predefinite dell'applicazione(ADC). Per saperne di più, vedi Configura ADC per un ambiente di sviluppo locale.
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 in Managed Service per Apache Kafka, configura le Credenziali predefinite dell'applicazione. Per saperne di più, consulta Configura ADC per un ambiente di sviluppo locale.
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 in Managed Service per Apache Kafka, configura le Credenziali predefinite dell'applicazione. Per saperne di più, vedi Configura ADC per un ambiente di sviluppo locale.
Visualizzare le proprietà e le risorse del cluster
Le sezioni seguenti descrivono come ottenere dettagli su varie proprietà e risorse associate a un cluster Google Cloud 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. L'indirizzo di bootstrap è fisso per l'intera durata di un cluster, ma il formato dell'URL di bootstrap potrebbe variare da un cluster all'altro.
Se l'accesso pubblico è abilitato per il cluster, l'indirizzo di bootstrap viene risolto automaticamente in indirizzi IP pubblici o privati a seconda della posizione da cui si connette il client (utilizzando DNS split-horizon). I client interni ed esterni devono utilizzare lo stesso indirizzo di bootstrap per connettersi al cluster. Non configurare i client Kafka per la connessione ai record DNS di rilevamento, che sono riservati solo per la configurazione dei firewall di uscita esterni.
Per ottenere l'indirizzo di bootstrap, segui questi passaggi:
Console
Vai alla pagina Managed Service per Apache Kafka > Cluster.
Fai clic sul nome del cluster.
Seleziona la scheda Configurazioni.
Se utilizzi SASL per l'autenticazione, l'URL di bootstrap è elencato in URL di bootstrap.
Se utilizzi TLS reciproca (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 comando managed-kafka clusters
describe.
Se utilizzi SASL per l'autenticazione, esegui questo comando:
gcloud managed-kafka clusters describe CLUSTER_ID \
--location=LOCATION \
--format="value(bootstrapAddress)"
Se utilizzi l'autenticazione TLS reciproca (mTLS), esegui questo 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 posizione del cluster.
Per saperne di più sull'autenticazione SASL e mTLS, consulta Tipi di autenticazione per i broker Kafka.
Intermediari
Per visualizzare i broker nel cluster, consulta Visualizzare i broker in un cluster Managed Service per Apache Kafka.
Gruppi di consumer
Un gruppo di consumatori è un insieme di consumatori che collaborano per utilizzare i dati di vari argomenti. Per visualizzare i gruppi di consumatori per un cluster, consulta le seguenti pagine:
Subnet
Per visualizzare le subnet collegate al cluster, segui questi passaggi:
Console
Nella console Google Cloud , vai alla pagina Cluster.
Fai clic sul nome del cluster.
Nella pagina dei dettagli del cluster, fai clic sulla scheda Configurazioni. Le subnet connesse sono elencate in Subnet.
gcloud
Esegui il comando
gcloud managed-kafka clusters describe: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 posizione del cluster.
Per maggiori informazioni, vedi Configura il networking per Managed Service per Apache Kafka.
Intervalli IP di origine consentiti
Per visualizzare gli intervalli IP di origine consentiti per un cluster pubblico:
Console
Nella console Google Cloud , vai alla pagina Cluster.
Fai clic sul nome del cluster.
Fai clic sulla scheda Configurazioni. Gli intervalli IP di origine consentiti sono elencati nella tabella Intervalli IP di origine consentiti nella colonna Intervallo IP.
gcloud
Per visualizzare gli intervalli IP di origine consentiti utilizzando
gcloud, controlla il campogcpConfig.accessConfig.publicClusterConfig.allowedSourceIpRangesnella risposta del comandogcloud managed-kafka clusters describe:gcloud managed-kafka clusters describe CLUSTER_ID \ --location=LOCATION \ --format="yaml(gcpConfig.accessConfig.publicClusterConfig.allowedSourceIpRanges)"Sostituisci quanto segue:
- CLUSTER_ID: l'ID o il nome del cluster.
- LOCATION: la posizione del cluster.
REST
Per visualizzare gli intervalli IP di origine consentiti utilizzando l'API REST, controlla il campo
gcpConfig.accessConfig.publicClusterConfig.allowedSourceIpRanges nella risposta di
una richiesta GET:
Prima di utilizzare i dati della richiesta, apporta le sostituzioni seguenti:
-
PROJECT_ID: il tuo Google Cloud ID progetto -
LOCATION: la posizione 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 del cluster, incluse le informazioni sui broker del cluster e il numero di versione di Kafka in esecuzione nel cluster.
Se non specificato, il metodo predefinito è
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"
}
],
"publicClusterConfig": {
"allowedSourceIpRanges": [
"203.0.113.5/32"
]
}
}
},
"state": "ACTIVE",
"satisfiesPzi": false,
"satisfiesPzs": false,
"tlsConfig": {
"trustConfig": {}
},
"updateOptions": {},
"publicClusterDetails": {
"discoveryDnsRecords": [
"discovery-1.CLUSTER_ID.LOCATION.managedkafka.PROJECT_ID.cloud.goog"
],
"externalIpAddresses": [
"203.0.113.1",
"203.0.113.2",
"203.0.113.3",
"203.0.113.4"
]
}
}
Per saperne di più sugli intervalli IP di origine consentiti, consulta Cluster pubblici.
Dettagli del cluster pubblico
Per visualizzare i dettagli del cluster pubblico, inclusi gli indirizzi IP esterni e i record DNS di rilevamento, segui questi passaggi:
Console
Nella console Google Cloud , vai alla pagina Cluster.
Fai clic sul nome del cluster.
Fai clic sulla scheda Configurazioni. Gli indirizzi IP esterni e i record DNS di rilevamento sono elencati nei campi Indirizzi IP esterni e Record DNS di rilevamento.
gcloud
Esegui il comando
gcloud managed-kafka clusters describe:gcloud managed-kafka clusters describe CLUSTER_ID \ --location=LOCATION \ --format="yaml(publicClusterDetails)"Sostituisci quanto segue:
- CLUSTER_ID: l'ID o il nome del cluster.
- LOCATION: la posizione del cluster.
REST
Per visualizzare i dettagli del cluster pubblico utilizzando l'API REST, controlla il campo publicClusterDetails nella risposta di una richiesta GET:
Prima di utilizzare i dati della richiesta, apporta le sostituzioni seguenti:
-
PROJECT_ID: il tuo Google Cloud ID progetto -
LOCATION: la posizione 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 del cluster, incluse le informazioni sui broker del cluster e il numero di versione di Kafka in esecuzione nel cluster.
Se non specificato, il metodo predefinito è
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"
}
],
"publicClusterConfig": {
"allowedSourceIpRanges": [
"203.0.113.5/32"
]
}
}
},
"state": "ACTIVE",
"satisfiesPzi": false,
"satisfiesPzs": false,
"tlsConfig": {
"trustConfig": {}
},
"updateOptions": {},
"publicClusterDetails": {
"discoveryDnsRecords": [
"discovery-1.CLUSTER_ID.LOCATION.managedkafka.PROJECT_ID.cloud.goog"
],
"externalIpAddresses": [
"203.0.113.1",
"203.0.113.2",
"203.0.113.3",
"203.0.113.4"
]
}
}
Argomenti
Per visualizzare gli argomenti in un cluster, consulta le seguenti pagine: