Para ver un clúster, puedes usar la consola de Google Cloud , Google Cloud CLI, la biblioteca cliente o la API de Managed Kafka. No puedes usar la API de Apache Kafka de código abierto para ver un clúster.
Roles y permisos obligatorios para ver un clúster
Para obtener los permisos que necesitas
para ver un clúster,
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 ver un clúster. Para ver los permisos exactos que son necesarios, expande la sección Permisos requeridos:
Permisos necesarios
Se requieren los siguientes permisos para ver un clúster:
-
Lista de clústeres:
managedkafka.clusters.list -
Obtén detalles del clúster:
managedkafka.clusters.get
También puedes obtener estos permisos con roles personalizados o con otros roles predefinidos.
Cómo ver un clúster
Para ver un clúster, sigue estos pasos:
Console
En la consola de Google Cloud , ve a la página Clústeres.
Se muestran los clústeres que creaste en un proyecto.
Para ver un clúster específico, haz clic en su nombre.
Se abrirá la página de detalles del clúster. Esta página tiene las siguientes pestañas:
- Recursos: Muestra la lista de temas y grupos de consumidores asociados con el clúster.
- Control de acceso: Muestra las entradas de la LCA del clúster.
- Configuraciones: Muestra la configuración del clúster, incluida la lista de subredes asociadas con el clúster.
- Monitoring: Muestra las alertas de supervisión asociadas con el clúster.
- Registros: Muestra los registros relacionados con los clústeres del Explorador de registros.
- Fuentes: Proporciona accesos directos para crear conectores de origen de Kafka Connect o generar datos de prueba sintéticos.
- Receptores: Proporciona accesos directos para crear conectores receptores de Kafka Connect.
gcloud
-
En la consola de Google Cloud , activa Cloud Shell.
En la parte inferior de la consola de Google Cloud , se inicia una sesión de Cloud Shell en la que se muestra una ventana de línea de comandos. Cloud Shell es un entorno de shell con Google Cloud CLI ya instalada y con valores ya establecidos para el proyecto actual. La sesión puede tardar unos segundos en inicializarse.
Antes de usar cualquiera de los datos de comando a continuación, haz los siguientes reemplazos:
-
PROJECT_ID: Es el ID del proyecto. -
LOCATION: Es la ubicación del clúster. -
CLUSTER_ID: Es el ID del clúster.
Ejecuta el siguiente 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
Deberías recibir una respuesta similar a la que figura a continuación:
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
Antes de usar cualquiera de los datos de solicitud a continuación, realiza los siguientes reemplazos:
-
PROJECT_ID: ID del proyecto de Google Cloud -
LOCATION: Es la ubicación del clúster. -
CLUSTER_ID: Es el ID del clúster. -
CLUSTER_VIEW: Es la cantidad de metadatos que se devolverán. Especifica uno de los siguientes valores:CLUSTER_VIEW_BASIC: Devuelve los metadatos básicos del clúster.CLUSTER_VIEW_FULL: Devuelve todos los metadatos del clúster, incluida la información sobre los intermediarios del clúster y el número de versión de Kafka que ejecuta el clúster.
Si no se especifica, el método predeterminado es
CLUSTER_VIEW_BASIC.
Método HTTP y URL:
GET https://managedkafka.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/clusters/CLUSTER_ID?view=CLUSTER_VIEW
Para enviar tu solicitud, expande una de estas opciones:
Deberías recibir una respuesta JSON similar a la que se muestra a continuación:
{
"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"
]
}
}
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 para 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.
Java
Antes de probar este ejemplo, sigue las instrucciones de configuración para Java que encontrarás 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 para Apache Kafka.
Para autenticarte en Managed Service 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.
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 para Apache Kafka.
Para autenticarte en Managed Service 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.
Visualiza las propiedades y los recursos del clúster
En las siguientes secciones, se describe cómo obtener detalles sobre diversas propiedades y recursos asociados a un clúster de Google Cloud Managed Service para Apache Kafka.
Dirección de arranque
Los clientes de Kafka usan la dirección de inicio del clúster para establecer una conexión con él. La dirección de arranque es fija durante la vida útil de un clúster, pero el formato de la URL de arranque puede diferir entre los clústeres.
Si tu clúster tiene habilitado el acceso público, la dirección de arranque se resuelve automáticamente en direcciones IP públicas o privadas, según desde dónde se conecte el cliente (con DNS de horizonte dividido). Tanto los clientes internos como los externos deben usar la misma dirección de arranque para conectarse al clúster. No configures los clientes de Kafka para que se conecten a los registros DNS de descubrimiento, que se reservan solo para configurar firewalls de salida externos.
Para obtener la dirección de arranque, realiza los siguientes pasos:
Console
Ve a la página Clústeres de Managed Service para Apache Kafka >.
Haz clic en el nombre del clúster.
Selecciona la pestaña Configurations.
Si usas SASL para la autenticación, la URL de arranque se muestra en Bootstrap URL.
Si usas TLS mutua (mTLS) para la autenticación, la URL de arranque se muestra en URL de arranque de mTLS.
Haz clic en Copiar para copiar el valor.
gcloud
Para obtener la URL de arranque, usa el comando managed-kafka clusters
describe.
Si usas SASL para la autenticación, ejecuta el siguiente comando:
gcloud managed-kafka clusters describe CLUSTER_ID \
--location=LOCATION \
--format="value(bootstrapAddress)"
Si usas la TLS mutua (mTLS) para la autenticación, ejecuta el siguiente comando:
gcloud managed-kafka clusters describe CLUSTER_ID \
--location=LOCATION \
--format="value(bootstrapAddressMTLS)"
Reemplaza lo siguiente:
- CLUSTER_ID: Es el ID o el nombre del clúster.
- LOCATION: Es la ubicación del clúster.
Para obtener más información sobre la autenticación SASL y mTLS, consulta Tipos de autenticación para los agentes de Kafka.
Agentes
Para ver los agentes de tu clúster, consulta Cómo ver los agentes en un clúster de Managed Service para Apache Kafka.
Grupos de consumidores
Un grupo de consumidores es un conjunto de consumidores que cooperan para consumir datos de varios temas. Para ver los grupos de consumidores de un clúster, consulta las siguientes páginas:
Subredes
Para ver las subredes que están conectadas a tu clúster, realiza los siguientes pasos:
Console
En la consola de Google Cloud , ve a la página Clústeres.
Haz clic en el nombre del clúster.
En la página de detalles del clúster, haz clic en la pestaña Configuraciones. Las subredes conectadas se enumeran en Subredes.
gcloud
Ejecuta el comando
gcloud managed-kafka clusters describe:gcloud managed-kafka clusters describe CLUSTER_ID \ --location=LOCATION \ --format="yaml(gcpConfig.accessConfig.networkConfigs)"Reemplaza lo siguiente:
- CLUSTER_ID: Es el ID o el nombre del clúster.
- LOCATION: Es la ubicación del clúster.
Para obtener más información, consulta Configura las redes para Managed Service para Apache Kafka.
Rangos de IP de origen permitidos
Para ver los rangos de IP de origen permitidos para un clúster público, realiza los siguientes pasos:
Console
En la consola de Google Cloud , ve a la página Clústeres.
Haz clic en el nombre del clúster.
Haz clic en la pestaña Configurations. Los rangos de IP de origen permitidos se enumeran en la tabla Rangos de IP de origen permitidos, en la columna Rango de IP.
gcloud
Para ver los rangos de IP de origen permitidos con
gcloud, verifica el campogcpConfig.accessConfig.publicClusterConfig.allowedSourceIpRangesen la respuesta del comandogcloud managed-kafka clusters describe:gcloud managed-kafka clusters describe CLUSTER_ID \ --location=LOCATION \ --format="yaml(gcpConfig.accessConfig.publicClusterConfig.allowedSourceIpRanges)"Reemplaza lo siguiente:
- CLUSTER_ID: Es el ID o el nombre del clúster.
- LOCATION: Es la ubicación del clúster.
REST
Para ver los rangos de IP de origen permitidos con la API de REST, verifica el campo gcpConfig.accessConfig.publicClusterConfig.allowedSourceIpRanges en la respuesta de una solicitud GET:
Antes de usar cualquiera de los datos de solicitud a continuación, realiza los siguientes reemplazos:
-
PROJECT_ID: ID del proyecto de Google Cloud -
LOCATION: Es la ubicación del clúster. -
CLUSTER_ID: Es el ID del clúster. -
CLUSTER_VIEW: Es la cantidad de metadatos que se devolverán. Especifica uno de los siguientes valores:CLUSTER_VIEW_BASIC: Devuelve los metadatos básicos del clúster.CLUSTER_VIEW_FULL: Devuelve todos los metadatos del clúster, incluida la información sobre los intermediarios del clúster y el número de versión de Kafka que ejecuta el clúster.
Si no se especifica, el método predeterminado es
CLUSTER_VIEW_BASIC.
Método HTTP y URL:
GET https://managedkafka.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/clusters/CLUSTER_ID?view=CLUSTER_VIEW
Para enviar tu solicitud, expande una de estas opciones:
Deberías recibir una respuesta JSON similar a la que se muestra a continuación:
{
"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"
]
}
}
Para obtener más información sobre los rangos de IP de origen permitidos, consulta Clústeres públicos.
Detalles del clúster público
Para ver los detalles del clúster público, incluidas las direcciones IP externas y los registros DNS de detección, realiza los siguientes pasos:
Console
En la consola de Google Cloud , ve a la página Clústeres.
Haz clic en el nombre del clúster.
Haz clic en la pestaña Configurations. Las direcciones IP externas y los registros DNS de detección se muestran en los campos Direcciones IP externas y Registros DNS de detección.
gcloud
Ejecuta el comando
gcloud managed-kafka clusters describe:gcloud managed-kafka clusters describe CLUSTER_ID \ --location=LOCATION \ --format="yaml(publicClusterDetails)"Reemplaza lo siguiente:
- CLUSTER_ID: Es el ID o el nombre del clúster.
- LOCATION: Es la ubicación del clúster.
REST
Para ver los detalles del clúster público con la API de REST, consulta el campo publicClusterDetails en la respuesta de una solicitud GET:
Antes de usar cualquiera de los datos de solicitud a continuación, realiza los siguientes reemplazos:
-
PROJECT_ID: ID del proyecto de Google Cloud -
LOCATION: Es la ubicación del clúster. -
CLUSTER_ID: Es el ID del clúster. -
CLUSTER_VIEW: Es la cantidad de metadatos que se devolverán. Especifica uno de los siguientes valores:CLUSTER_VIEW_BASIC: Devuelve los metadatos básicos del clúster.CLUSTER_VIEW_FULL: Devuelve todos los metadatos del clúster, incluida la información sobre los intermediarios del clúster y el número de versión de Kafka que ejecuta el clúster.
Si no se especifica, el método predeterminado es
CLUSTER_VIEW_BASIC.
Método HTTP y URL:
GET https://managedkafka.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/clusters/CLUSTER_ID?view=CLUSTER_VIEW
Para enviar tu solicitud, expande una de estas opciones:
Deberías recibir una respuesta JSON similar a la que se muestra a continuación:
{
"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"
]
}
}
Temas
Para ver los temas de un clúster, consulta las siguientes páginas: