Google verwendet KI-Technologie, um Inhalte in Ihre bevorzugte Sprache zu übersetzen. KI-Übersetzungen können Fehler enthalten.

Google Cloud Managed Service for Apache Kafka-Cluster ansehen

Sie können einen Cluster über die Google Cloud Console, die Google Cloud CLI, die Clientbibliothek oder die Managed Kafka API aufrufen. Sie können die Open-Source-Apache Kafka API nicht verwenden, um einen Cluster aufzurufen.

Erforderliche Rollen und Berechtigungen zum Aufrufen eines Clusters

Bitten Sie Ihren Administrator, Ihnen die IAM-Rolle Managed Kafka Viewer (roles/managedkafka.viewer) für Ihr Projekt zuzuweisen, um die Berechtigungen zu erhalten, die Sie zum Aufrufen eines Clusters benötigen. Weitere Informationen zum Zuweisen von Rollen finden Sie unter Zugriff auf Projekte, Ordner und Organisationen verwalten.

Diese vordefinierte Rolle enthält die Berechtigungen, die zum Aufrufen eines Clusters erforderlich sind. Maximieren Sie den Abschnitt Erforderliche Berechtigungen, um die notwendigen Berechtigungen anzuzeigen:

Erforderliche Berechtigungen

Die folgenden Berechtigungen sind erforderlich, um einen Cluster aufzurufen:

Cluster auflisten: managedkafka.clusters.list
Clusterdetails abrufen: managedkafka.clusters.get

Sie können diese Berechtigungen auch mit benutzerdefinierten Rollen oder anderen vordefinierten Rollen erhalten.

Cluster ansehen

So rufen Sie einen Cluster auf:

Console

Rufen Sie in der Google Cloud Console die Seite Cluster auf.

Zu den Clustern

Die Cluster, die Sie in einem Projekt erstellt haben, werden aufgelistet.
Wenn Sie einen bestimmten Cluster aufrufen möchten, klicken Sie auf den Clusternamen.
Die Cluster-Detailseite wird geöffnet. Diese Seite enthält die folgenden Tabs:
- Ressourcen: Zeigt die Liste der Themen und Nutzergruppen an, die mit dem Cluster verknüpft sind.
- Zugriffssteuerung: Zeigt die ACL-Einträge für den Cluster an.
- Konfigurationen: Zeigt die Konfiguration des Clusters an, einschließlich der Liste der mit dem Cluster verknüpften Subnetze.
- Monitoring: Zeigt die Monitoring-Benachrichtigungen an, die mit dem Cluster verknüpft sind.
- Logs: Zeigt die Logs zu Clustern aus dem Log-Explorer an.
- Quellen: Bietet Verknüpfungen zum Erstellen von Kafka Connect-Quell-Connectors oder zum Generieren von synthetischen Testdaten.
- Senken: Bietet Verknüpfungen zum Erstellen von Kafka Connect-Senken-Connectors.

gcloud

Aktivieren Sie Cloud Shell in der Google Cloud Console.

Cloud Shell aktivieren

Unten in der Google Cloud Console wird eine Cloud Shell-Sitzung gestartet und eine Eingabeaufforderung angezeigt. Cloud Shell ist eine Shell-Umgebung, in der das Google Cloud CLI bereits installiert ist und Werte für Ihr aktuelles Projekt bereits festgelegt sind. Das Initialisieren der Sitzung kann einige Sekunden dauern.

Ersetzen Sie folgende Werte, bevor sie einen der Befehlsdaten verwenden:

PROJECT_ID: Projekt-ID.
LOCATION: Der Standort des Clusters.
CLUSTER_ID: die ID des Clusters.

Führen Sie folgenden Befehl aus:

Linux, macOS oder 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

Sie sollten eine Antwort ähnlich der folgenden erhalten:

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

Ersetzen Sie diese Werte in den folgenden Anfragedaten:

PROJECT_ID: Ihre Google Cloud -Projekt-ID
LOCATION: Der Standort des Clusters.
CLUSTER_ID: die ID des Clusters.
CLUSTER_VIEW: die Menge der zurückzugebenden Metadaten. Geben Sie einen der folgenden Werte an:
- CLUSTER_VIEW_BASIC: Gibt die grundlegenden Metadaten für den Cluster zurück.
- CLUSTER_VIEW_FULL: Gibt alle Metadaten für den Cluster zurück, einschließlich Informationen zu den Brokern des Clusters und der Kafka-Versionsnummer, die auf dem Cluster ausgeführt wird.
Wenn keine Angabe erfolgt, wird standardmäßig die Methode CLUSTER_VIEW_BASIC verwendet.

HTTP-Methode und URL:

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

Wenn Sie die Anfrage senden möchten, maximieren Sie eine der folgenden Optionen:

curl (Linux, macOS oder Cloud Shell)

Hinweis: Der folgende Befehl setzt voraus, dass Sie sich mit Ihrem Nutzerkonto in der gcloud-Befehlszeile angemeldet haben, indem Sie gcloud init oder gcloud auth login ausgeführt oder die Cloud Shell genutzt haben, die Sie automatisch in der gcloud-Befehlszeile anmeldet. Um herauszufinden, welches Konto gerade aktiv ist, führen Sie gcloud auth list aus.

Führen Sie folgenden Befehl aus:

curl -X GET \
     -H "Authorization: Bearer $(gcloud auth print-access-token)" \
     "https://managedkafka.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/clusters/CLUSTER_ID?view=CLUSTER_VIEW"

PowerShell (Windows)

Hinweis: Der folgende Befehl setzt voraus, dass Sie sich mit Ihrem Nutzerkonto in der gcloud-Befehlszeile angemeldet haben, indem Sie gcloud init oder gcloud auth login ausgeführt haben. Um herauszufinden, welches Konto gerade aktiv ist, führen Sie gcloud auth list aus.

Führen Sie folgenden Befehl aus:

$cred = gcloud auth print-access-token
$headers = @{ "Authorization" = "Bearer $cred" }

Invoke-WebRequest `
    -Method GET `
    -Headers $headers `
    -Uri "https://managedkafka.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/clusters/CLUSTER_ID?view=CLUSTER_VIEW" | Select-Object -Expand Content

Sie sollten in etwa folgende JSON-Antwort erhalten:

{
  "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

Bevor Sie dieses Beispiel ausprobieren, folgen Sie der Einrichtungsanleitung für Go unter Clientbibliotheken installieren. Weitere Informationen finden Sie in der API-Referenzdokumentation für Managed Service for Apache Kafka Go.

Richten Sie zur Authentifizierung bei Managed Service for Apache Kafka Standardanmeldedaten für Anwendungen(Application Default Credentials, ADC) ein. Weitere Informationen finden Sie unter Standardanmeldedaten für Anwendungen für eine lokale Entwicklungsumgebung einrichten.

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

Bevor Sie dieses Beispiel ausprobieren, folgen Sie der Anleitung zur Einrichtung von Java unter Clientbibliotheken installieren. Weitere Informationen finden Sie in der Referenzdokumentation zur Managed Service for Apache Kafka Java API.

Richten Sie die Standardanmeldedaten für Anwendungen ein, um sich bei Managed Service for Apache Kafka zu authentifizieren. Weitere Informationen finden Sie unter Standardanmeldedaten für Anwendungen für eine lokale Entwicklungsumgebung einrichten.

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

Bevor Sie dieses Beispiel ausprobieren, folgen Sie der Einrichtungsanleitung für Python unter Clientbibliotheken installieren. Weitere Informationen finden Sie in der Referenzdokumentation zur Managed Service for Apache Kafka Python API.

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}")

Clustereigenschaften und -ressourcen ansehen

In den folgenden Abschnitten wird beschrieben, wie Sie Details zu verschiedenen Attributen und Ressourcen abrufen, die mit einem Google Cloud Managed Service for Apache Kafka-Cluster verknüpft sind.

Bootstrap-Adresse

Kafka-Clients verwenden die Bootstrap-Adresse des Clusters, um eine Verbindung zum Cluster herzustellen. Die Bootstrap-Adresse ist für die Lebensdauer eines Clusters festgelegt, das Format der Bootstrap-URL kann sich jedoch von Cluster zu Cluster unterscheiden.

Wenn für Ihren Cluster der öffentliche Zugriff aktiviert ist, wird die Bootstrap-Adresse automatisch in öffentliche oder private IP-Adressen aufgelöst, je nachdem, von wo aus der Client eine Verbindung herstellt (mit Split-Horizon-DNS). Sowohl interne als auch externe Clients sollten diese Bootstrap-Adresse verwenden, um eine Verbindung zum Cluster herzustellen. Konfigurieren Sie Kafka-Clients nicht so, dass sie eine Verbindung zu DNS-Einträgen für die Erkennung herstellen, die nur für die Konfiguration externer Firewalls für ausgehenden Traffic reserviert sind.

So rufen Sie die Bootstrap-Adresse ab:

Console

Rufen Sie die Seite Managed Service for Apache Kafka > Cluster auf.

Zu den Clustern
Klicken Sie auf den Namen des Clusters.
Wählen Sie den Tab Konfigurationen aus.
Wenn Sie SASL zur Authentifizierung verwenden, wird die Bootstrap-URL unter Bootstrap-URL aufgeführt.

Wenn Sie gegenseitiges TLS (mTLS) für die Authentifizierung verwenden, wird die Bootstrap-URL unter mTLS-Bootstrap-URL aufgeführt.

Klicken Sie auf Kopieren, um den Wert zu kopieren.

gcloud

Verwenden Sie den Befehl managed-kafka clusters describe, um die Bootstrap-URL abzurufen.

Wenn Sie SASL zur Authentifizierung verwenden, führen Sie den folgenden Befehl aus:

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

Wenn Sie gegenseitiges TLS (mTLS) zur Authentifizierung verwenden, führen Sie den folgenden Befehl aus:

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

Ersetzen Sie Folgendes:

CLUSTER_ID: Die ID oder der Name des Clusters.
LOCATION: Der Standort des Clusters.

Wenn Sie eine Bootstrap-Adresse haben und den entsprechenden Cluster finden möchten, können Sie die Clusterliste in der Google Cloud Console filtern oder gcloud managed-kafka clusters list mit --filter="bootstrapAddress:BOOTSTRAP_ADDRESS" ausführen. Weitere Informationen finden Sie unter Cluster auflisten.

Weitere Informationen zur SASL- und mTLS-Authentifizierung finden Sie unter Authentifizierungstypen für Kafka-Broker.

Makler

Informationen zum Aufrufen der Broker in Ihrem Cluster finden Sie unter Broker in einem Managed Service for Apache Kafka-Cluster ansehen.

Verbrauchergruppen

Eine Nutzergruppe ist eine Gruppe von Nutzern, die zusammenarbeiten, um Daten aus verschiedenen Themen zu nutzen. Informationen zum Aufrufen der Nutzergruppen für einen Cluster finden Sie auf den folgenden Seiten:

Subnetzwerke

So rufen Sie die Subnetzwerke auf, die mit Ihrem Cluster verbunden sind:

Console

Rufen Sie in der Google Cloud Console die Seite Cluster auf.

Zu den Clustern
Klicken Sie auf den Namen des Clusters.
Klicken Sie auf der Cluster-Detailseite auf den Tab Konfigurationen. Verbundene Subnetzwerke werden unter Subnetzwerke aufgeführt.

gcloud

Zum Abrufen der aktuellen Richtlinie führen Sie den Befehl gcloud managed-kafka clusters describe aus:
```
gcloud managed-kafka clusters describe CLUSTER_ID \
    --location=LOCATION \
    --format="yaml(gcpConfig.accessConfig.networkConfigs)"
```
Ersetzen Sie Folgendes:
- CLUSTER_ID: Die ID oder der Name des Clusters.
- LOCATION: Der Standort des Clusters.

Weitere Informationen finden Sie unter Netzwerk für Managed Service for Apache Kafka konfigurieren.

Zulässige Quell-IP-Bereiche

So rufen Sie die zulässigen Quell-IP-Bereiche für einen öffentlichen Cluster auf:

Console

Rufen Sie in der Google Cloud Console die Seite Cluster auf.

Zu den Clustern
Klicken Sie auf den Namen des Clusters.
Klicken Sie auf den Tab Konfigurationen. Die zulässigen Quell-IP-Bereiche sind in der Tabelle Zulässige Quell-IP-Bereiche in der Spalte IP-Bereich aufgeführt.

gcloud

Wenn Sie die zulässigen Quell-IP-Bereiche mit gcloud aufrufen möchten, prüfen Sie das Feld gcpConfig.accessConfig.publicClusterConfig.allowedSourceIpRanges in der Antwort des Befehls gcloud managed-kafka clusters describe:
```
gcloud managed-kafka clusters describe CLUSTER_ID \
    --location=LOCATION \
    --format="yaml(gcpConfig.accessConfig.publicClusterConfig.allowedSourceIpRanges)"
```
Ersetzen Sie Folgendes:
- CLUSTER_ID: Die ID oder der Name des Clusters.
- LOCATION: Der Standort des Clusters.

REST

Wenn Sie die zulässigen Quell-IP-Bereiche mit der REST API aufrufen möchten, prüfen Sie das Feld gcpConfig.accessConfig.publicClusterConfig.allowedSourceIpRanges in der Antwort einer GET-Anfrage:

Ersetzen Sie diese Werte in den folgenden Anfragedaten:

PROJECT_ID: Ihre Google Cloud -Projekt-ID
LOCATION: Der Standort des Clusters.
CLUSTER_ID: die ID des Clusters.
CLUSTER_VIEW: die Menge der zurückzugebenden Metadaten. Geben Sie einen der folgenden Werte an:
- CLUSTER_VIEW_BASIC: Gibt die grundlegenden Metadaten für den Cluster zurück.
- CLUSTER_VIEW_FULL: Gibt alle Metadaten für den Cluster zurück, einschließlich Informationen zu den Brokern des Clusters und der Kafka-Versionsnummer, die auf dem Cluster ausgeführt wird.
Wenn keine Angabe erfolgt, wird standardmäßig die Methode CLUSTER_VIEW_BASIC verwendet.

HTTP-Methode und URL:

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

Wenn Sie die Anfrage senden möchten, maximieren Sie eine der folgenden Optionen:

curl (Linux, macOS oder Cloud Shell)

Führen Sie folgenden Befehl aus:

curl -X GET \
     -H "Authorization: Bearer $(gcloud auth print-access-token)" \
     "https://managedkafka.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/clusters/CLUSTER_ID?view=CLUSTER_VIEW"

PowerShell (Windows)

Hinweis: Der folgende Befehl setzt voraus, dass Sie sich mit Ihrem Nutzerkonto in der gcloud-Befehlszeile angemeldet haben, indem Sie gcloud init oder gcloud auth login ausgeführt haben. Um herauszufinden, welches Konto gerade aktiv ist, führen Sie gcloud auth list aus.

Führen Sie folgenden Befehl aus:

$cred = gcloud auth print-access-token
$headers = @{ "Authorization" = "Bearer $cred" }

Invoke-WebRequest `
    -Method GET `
    -Headers $headers `
    -Uri "https://managedkafka.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/clusters/CLUSTER_ID?view=CLUSTER_VIEW" | Select-Object -Expand Content

Sie sollten eine JSON-Antwort ähnlich wie diese erhalten:

{
  "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"
    ]
  }
}

Weitere Informationen zu zulässigen Quell-IP-Bereichen finden Sie unter Öffentliche Cluster.

Details zum öffentlichen Cluster

So rufen Sie die Details des öffentlichen Clusters auf, einschließlich der externen IP-Adressen und der DNS-Einträge für die Erkennung:

Console

Rufen Sie in der Google Cloud Console die Seite Cluster auf.

Zu den Clustern
Klicken Sie auf den Namen des Clusters.
Klicken Sie auf den Tab Konfigurationen. Die externen IP-Adressen und DNS-Einträge für die Erkennung sind in den Feldern Externe IP-Adressen und DNS-Einträge für die Erkennung aufgeführt.

gcloud

Zum Abrufen der aktuellen Richtlinie führen Sie den Befehl gcloud managed-kafka clusters describe aus:
```
gcloud managed-kafka clusters describe CLUSTER_ID \
    --location=LOCATION \
    --format="yaml(publicClusterDetails)"
```
Ersetzen Sie Folgendes:
- CLUSTER_ID: Die ID oder der Name des Clusters.
- LOCATION: Der Standort des Clusters.

REST

Wenn Sie die Details des öffentlichen Clusters mit der REST API aufrufen möchten, prüfen Sie das Feld publicClusterDetails in der Antwort einer GET-Anfrage:

Ersetzen Sie diese Werte in den folgenden Anfragedaten:

PROJECT_ID: Ihre Google Cloud -Projekt-ID
LOCATION: Der Standort des Clusters.
CLUSTER_ID: die ID des Clusters.
CLUSTER_VIEW: die Menge der zurückzugebenden Metadaten. Geben Sie einen der folgenden Werte an:
- CLUSTER_VIEW_BASIC: Gibt die grundlegenden Metadaten für den Cluster zurück.
- CLUSTER_VIEW_FULL: Gibt alle Metadaten für den Cluster zurück, einschließlich Informationen zu den Brokern des Clusters und der Kafka-Versionsnummer, die auf dem Cluster ausgeführt wird.
Wenn keine Angabe erfolgt, wird standardmäßig die Methode CLUSTER_VIEW_BASIC verwendet.

HTTP-Methode und URL:

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

Wenn Sie die Anfrage senden möchten, maximieren Sie eine der folgenden Optionen:

curl (Linux, macOS oder Cloud Shell)

Führen Sie folgenden Befehl aus:

curl -X GET \
     -H "Authorization: Bearer $(gcloud auth print-access-token)" \
     "https://managedkafka.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/clusters/CLUSTER_ID?view=CLUSTER_VIEW"

PowerShell (Windows)

Hinweis: Der folgende Befehl setzt voraus, dass Sie sich mit Ihrem Nutzerkonto in der gcloud-Befehlszeile angemeldet haben, indem Sie gcloud init oder gcloud auth login ausgeführt haben. Um herauszufinden, welches Konto gerade aktiv ist, führen Sie gcloud auth list aus.

Führen Sie folgenden Befehl aus:

$cred = gcloud auth print-access-token
$headers = @{ "Authorization" = "Bearer $cred" }

Invoke-WebRequest `
    -Method GET `
    -Headers $headers `
    -Uri "https://managedkafka.googleapis.com/v1/projects/PROJECT_ID/locations/LOCATION/clusters/CLUSTER_ID?view=CLUSTER_VIEW" | Select-Object -Expand Content

Sie sollten eine JSON-Antwort ähnlich wie diese erhalten:

{
  "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"
    ]
  }
}

Themen

Informationen zum Aufrufen der Themen in einem Cluster finden Sie auf den folgenden Seiten:

Nächste Schritte

Apache Kafka® ist eine eingetragene Marke der Apache Software Foundation oder deren Tochtergesellschaften in den USA und/oder anderen Ländern.

Google Cloud Managed Service for Apache Kafka-Cluster ansehen Mit Sammlungen den Überblick behalten Sie können Inhalte basierend auf Ihren Einstellungen speichern und kategorisieren.

Erforderliche Rollen und Berechtigungen zum Aufrufen eines Clusters

Erforderliche Berechtigungen

Cluster ansehen

Console

gcloud

Linux, macOS oder Cloud Shell

Windows (PowerShell)

Windows (cmd.exe)

REST

curl (Linux, macOS oder Cloud Shell)

PowerShell (Windows)

Go

Java

Python

Clustereigenschaften und -ressourcen ansehen

Bootstrap-Adresse

Console

gcloud

Makler

Verbrauchergruppen

Subnetzwerke

Console

gcloud

Zulässige Quell-IP-Bereiche

Console

gcloud

REST

curl (Linux, macOS oder Cloud Shell)

PowerShell (Windows)

Details zum öffentlichen Cluster

Console

gcloud

REST

curl (Linux, macOS oder Cloud Shell)

PowerShell (Windows)

Themen

Nächste Schritte

Google Cloud Managed Service for Apache Kafka-Cluster ansehen