Exclusão de um grupo de consumidores
Você pode excluir um grupo de consumidores usando um dos seguintes métodos:
- Método 1: excluir um grupo de consumidores no console.
- Método 2: usar CLI do Kafka para excluir um grupo de consumidores. (Certifique-se de que a versão da instância do Kafka seja igual à versão da CLI.)
Pré-requisitos
O status do grupo de consumidores a ser excluído é EMPTY.
Restrições
- Se auto.create.groups.enable estiver definido como true, o status do grupo de consumidores for EMPTY e nenhum deslocamento tiver sido enviado, o sistema excluirá automaticamente o grupo de consumidores 10 minutos depois.
- Se auto.create.groups.enable for definido como false, o sistema não excluirá automaticamente grupos de consumidores. Você pode excluí-los manualmente.
Método 1: excluir um grupo de consumidores no console
- Faça logon no console de gerenciamento.
- Clique em no canto superior esquerdo para selecionar uma região.
Selecione a região onde sua instância do Kafka está localizada.
- Clique em e escolha Middleware > Distributed Message Service (for Kafka) para abrir o console do DMS for Kafka.
- Clique na instância do Kafka desejada para exibir os detalhes da instância.
- No painel de navegação, escolha a guia Consumer Groups.
- Exclua grupos de consumidores usando um dos seguintes métodos:
- Selecione um ou mais grupos de consumidores e clique em Delete Consumer Group acima da lista de grupos de consumidores.
- Na linha que contém o grupo de consumidores que você deseja excluir, clique em Delete.
Um grupo de consumidores pode ser excluído somente quando seu status é EMPTY.
Os status do grupo de consumidores incluem:
- DEAD: o grupo de consumidores não tem nenhum membro ou metadados.
- EMPTY: o grupo de consumidores tem metadados, mas não tem nenhum membro.
- PREPARING_REBALANCE: o grupo de consumidores deve ser reequilibrado.
- COMPLETING_REBALANCE: todos os membros aderiram ao grupo de consumidores.
- STABLE: os membros do grupo de consumidores podem consumir mensagens normalmente.
- Na caixa de diálogo Delete Consumer Group exibida, clique em Yes.
Método 2: usar a CLI para excluir um grupo de consumidores
O seguinte usa o Linux como exemplo.
- Faça download da CLI do Kafka v1.1.0, v2.3.0 ou v2.7.2. Certifique-se de que a instância do Kafka e a CLI sejam da mesma versão.
- Use a CLI para se conectar à instância do Kafka. Para obter detalhes, consulte Acesso de uma instância do Kafka sem SASL ou Acesso de uma instância do Kafka com SASL.
- No diretório /{directory where the CLI is located}/kafka_{version}/bin/, execute o seguinte comando para excluir um grupo de consumidores:
./kafka-consumer-groups.sh --bootstrap-server {Kafka instance connection address} --delete --group {consumer group name}
[root@zk-server-1 bin]# ./kafka-consumer-groups.sh --bootstrap-server 192.168.1.245:9091,192.168.1.86:9091,192.168.1.128:9091 --delete --group bbbb Note: This will not show information about old Zookeeper-based consumers. Deletion of requested consumer groups ('bbbb') was successful.
Se a autenticação SASL estiver habilitada para a instância do Kafka, o parâmetro --command-config {consumer.properties file with SASL authentication} deve ser adicionado aos comandos anteriores. Para obter detalhes sobre o arquivo consumer.properties, consulte Acesso de uma instância do Kafka com SASL.