Google Cloud Managed Service for Apache Kafka-Consumergruppe löschen

Durch das Löschen einer Nutzergruppe wird diese aus Ihrem Managed Service for Apache Kafka-Cluster entfernt.

Zum Löschen einer Nutzergruppe können Sie die Google Cloud Console, die Google Cloud CLI, die Clientbibliotheken, die Managed Kafka API oder die Open-Source-Apache Kafka APIs verwenden.

Erforderliche Rollen und Berechtigungen zum Löschen einer Nutzergruppe

Bitten Sie Ihren Administrator, Ihnen die Bearbeiter von Managed Kafka-Nutzergruppen (roles/managedkafka.consumerGroupEditor) IAM-Rolle für Ihr Projekt zuzuweisen, damit Sie die Berechtigungen erhalten, die Sie zum Löschen Ihrer Nutzergruppen 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 Löschen Ihrer Nutzergruppen erforderlich sind. Maximieren Sie den Abschnitt Erforderliche Berechtigungen , um die notwendigen Berechtigungen anzuzeigen, die erforderlich sind:

Erforderliche Berechtigungen

Die folgenden Berechtigungen sind zum Löschen Ihrer Nutzergruppen erforderlich:

  • Nutzergruppen löschen: managedkafka.consumerGroups.delete

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

Weitere Informationen zur Rolle „Bearbeiter von Managed Kafka-Nutzergruppen“ finden Sie unter Vordefinierte Rollen für Managed Service for Apache Kafka.

Nutzergruppe löschen

Wenn Sie eine Nutzergruppe löschen, gehen die darin gespeicherten Nutzer-Offsets dauerhaft verloren. Außerdem können Sie die Logs und Messwerte für die Nutzergruppen nicht in der Console sehen. Die mit der Nutzergruppe verknüpften Messwerte und Logs bleiben jedoch erhalten und sind über den Log-Explorer zugänglich. Durch das Löschen einer Nutzergruppe werden auch die von ihr verarbeiteten Nachrichten nicht gelöscht. Die Nachrichten sind weiterhin in den Themen verfügbar, mit denen sie ursprünglich verknüpft waren.

So löschen Sie eine Nutzergruppe:

Console

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

    Zu den Clustern

  2. Klicken Sie in der Liste der Cluster auf den Cluster, zu dem die zu löschende Nutzergruppe gehört.

    Die Seite Clusterdetails wird geöffnet.

  3. Klicken Sie auf die Nutzergruppe, die Sie löschen möchten.
  4. Klicken Sie auf der Seite Details zur Nutzergruppe auf Löschen.
  5. Bestätigen Sie den Vorgang.

gcloud

  1. 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.

  2. Führen Sie den gcloud managed-kafka consumer-groups delete Befehl aus:

    gcloud managed-kafka consumer-groups delete CONSUMER_GROUP_ID \
    --cluster=CLUSTER_ID \
    --location=LOCATION

    Mit diesem Befehl wird eine Nutzergruppe dauerhaft aus Ihrem Managed Service for Apache Kafka-Cluster entfernt.

    Ersetzen Sie Folgendes:

    • CONSUMER_GROUP_ID: Die ID oder der Name der Nutzergruppe.

    • CLUSTER_ID: Die ID oder der Name des Clusters.

    • LOCATION: Der Standort des Clusters.

Go

import (
	"context"
	"fmt"
	"io"

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

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

func deleteConsumerGroup(w io.Writer, projectID, region, clusterID, consumerGroupID string, opts ...option.ClientOption) error {
	// projectID := "my-project-id"
	// region := "us-central1"
	// clusterID := "my-cluster"
	// consumerGroupID := "my-consumer-group"
	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)
	consumerGroupPath := fmt.Sprintf("%s/consumerGroups/%s", clusterPath, consumerGroupID)
	req := &managedkafkapb.DeleteConsumerGroupRequest{
		Name: consumerGroupPath,
	}
	if err := client.DeleteConsumerGroup(ctx, req); err != nil {
		return fmt.Errorf("client.DeleteConsumerGroup got err: %w", err)
	}
	fmt.Fprint(w, "Deleted consumer group\n")
	return nil
}

Java

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

public class DeleteConsumerGroup {

  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";
    String consumerGroupId = "my-consumer-group";
    deleteConsumerGroup(projectId, region, clusterId, consumerGroupId);
  }

  public static void deleteConsumerGroup(
      String projectId, String region, String clusterId, String consumerGroupId) throws Exception {
    try (ManagedKafkaClient managedKafkaClient = ManagedKafkaClient.create()) {
      // This operation is being handled synchronously.
      managedKafkaClient.deleteConsumerGroup(
          ConsumerGroupName.of(projectId, region, clusterId, consumerGroupId));
      System.out.println("Deleted consumer group");
    } catch (IOException | ApiException e) {
      System.err.printf("managedKafkaClient.getConsumerGroup got err: %s", e.getMessage());
    }
  }
}

Python

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"
# consumer_group_id = "my-consumer-group"

client = managedkafka_v1.ManagedKafkaClient()

consumer_group_path = client.consumer_group_path(
    project_id, region, cluster_id, consumer_group_id
)
request = managedkafka_v1.DeleteConsumerGroupRequest(
    name=consumer_group_path,
)

try:
    client.delete_consumer_group(request=request)
    print("Deleted consumer group")
except NotFound as e:
    print(f"Failed to delete consumer group {consumer_group_id} with error: {e.message}")

Nächste Schritte

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