Exclusão de uma mensagem

Cenário

Excluir mensagens no console.

Mensagens excluídas não podem ser recuperadas.

Pré-requisitos

Antes de excluir uma mensagem, defina o parâmetro auto.offset.reset no cliente. auto.offset.reset especifica a política de consumo de um consumidor quando não há deslocamento inicial no Kafka ou o deslocamento atual não existe (por exemplo, o deslocamento atual foi excluído). Opções:

• latest: o deslocamento é automaticamente redefinido para o deslocamento mais recente.
• earliest: o deslocamento é automaticamente redefinido para o deslocamento mais antigo.
• none: o sistema lança uma exceção ao consumidor.

Se este parâmetro for definido como latest, o produtor poderá começar a enviar mensagens para novas partições (se houver) antes que o consumidor redefina o deslocamento inicial. Como resultado, algumas mensagens serão perdidas.

Procedimento

1. Faça logon no console de gerenciamento.
2. Clique em no canto superior esquerdo para selecionar uma região.
   

   Selecione a região onde sua instância do Kafka está localizada.

3. Clique em e escolha Middleware > Distributed Message Service (for Kafka) para abrir o console do DMS for Kafka.
4. Clique na instância de Kafka desejada para visualizar seus detalhes.
5. No painel de navegação, escolha a guia Topics.
6. Na linha que contém o tópico cujas mensagens você deseja excluir, clique em Delete Messages. A caixa de diálogo Delete Messages é exibida.
7. Defina os parâmetros para excluir mensagens, conforme mostrado na Tabela 1.
   Figura 1 Excluir mensagens
   

   Tabela 1 Parâmetros para excluir uma mensagem

   Parâmetro	Descrição
   Partition	Selecione o ID da partição onde a mensagem está localizada.
   Offset	Insira o deslocamento. Os dados antes desse deslocamento serão excluídos. NOTA: Se Offset estiver definido como -1, todas as mensagens na partição serão excluídas. Se o deslocamento que você inseriu não estiver entre o deslocamento mais antigo e o mais recente da partição especificada, nenhuma mensagem será excluída.

   Para excluir mensagens de várias partições, clique em Add Partition e especifique a partição e o deslocamento das mensagens a serem excluídas. 10 partições podem ser excluídas no máximo de uma vez.

8. Clique em OK. A caixa de diálogo de Deletion Result é exibida. Clique em OK para excluir as mensagens.
   Figura 2 Resultado da exclusão