Excluir um grupo de consumidores do serviço gerenciado do Google Cloud para Apache Kafka

A exclusão de um grupo de consumidores remove um grupo do cluster do Serviço Gerenciado para Apache Kafka.

Para excluir um grupo de consumidores, use o console Google Cloud , a Google Cloud CLI, as bibliotecas de cliente, a API Managed Kafka ou as APIs Apache Kafka de código aberto.

Papéis e permissões necessárias para excluir um grupo de consumidores

Para receber as permissões necessárias para excluir seus grupos de consumidores, peça ao administrador para conceder a você o papel do IAM de Editor de grupos de consumidores gerenciados do Kafka (roles/managedkafka.consumerGroupEditor) no projeto. Para mais informações sobre a concessão de papéis, consulte Gerenciar o acesso a projetos, pastas e organizações.

Esse papel predefinido contém as permissões necessárias para excluir seus grupos de consumidores. Para acessar as permissões exatas necessárias, expanda a seção Permissões necessárias:

Permissões necessárias

As seguintes permissões são necessárias para excluir seus grupos de consumidores:

  • Excluir grupos de consumidores: managedkafka.consumerGroups.delete

Essas permissões também podem ser concedidas com funções personalizadas ou outros papéis predefinidos.

Excluir um grupo de consumidores

Quando você exclui um grupo de consumidores, os offsets que ele armazena são perdidos permanentemente. Também não é possível ver os registros e as métricas dos grupos de consumidores no console. No entanto, as métricas e os registros associados ao grupo de consumidores são mantidos e podem ser acessados usando a Análise de registros. A exclusão de um grupo de consumidores também não exclui as mensagens que ele consumiu. As mensagens ainda estão disponíveis nos tópicos com que foram associadas originalmente.

Para excluir um grupo de consumidores, siga estas etapas:

Console

  1. No console do Google Cloud , acesse a página Cluster.

    Acessar Clusters

  2. Na lista de clusters, clique no cluster a que o grupo de consumidores que você quer excluir pertence.

    A página Detalhes do cluster é aberta.

  3. Clique no grupo de consumidores que você quer excluir.
  4. Na página Detalhes do grupo de consumidores, clique em Excluir.
  5. Confirme a operação.

gcloud

  1. No console do Google Cloud , ative o Cloud Shell.

    Ativar o Cloud Shell

    Na parte de baixo do console Google Cloud , uma sessão do Cloud Shell é iniciada e exibe um prompt de linha de comando. O Cloud Shell é um ambiente shell com a CLI do Google Cloud já instalada e com valores já definidos para o projeto atual. A inicialização da sessão pode levar alguns segundos.

  2. Execute o comando gcloud managed-kafka consumer-groups delete:

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

    Esse comando remove permanentemente um grupo de consumidores do seu cluster do Serviço Gerenciado para Apache Kafka.

    Substitua:

    • CONSUMER_GROUP_ID: o ID ou nome do grupo de consumidores.

    • CLUSTER_ID: o ID ou nome do cluster.

    • LOCATION: o local do cluster.

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

A seguir

Apache Kafka® é uma marca registrada da The Apache Software Foundation ou afiliadas nos Estados Unidos e/ou em outros países.