Redefinição do deslocamento de consumidor
Redefinir o deslocamento do consumidor é alterar a posição de recuperação de um consumidor.
As mensagens podem ser recuperadas mais de uma vez depois que o deslocamento é redefinido. Tenha cuidado ao realizar esta operação.
Pré-requisitos
O deslocamento do consumidor não pode ser reiniciado em tempo real. Você deve primeiro interromper a recuperação do grupo de consumidores desejado.
Depois que um cliente é interrompido, o servidor considera o cliente off-line somente após o período especificado em ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG (1000 ms por padrão).
Procedimento
- 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.
- Clique no nome do grupo de consumidores desejado.
- Na página de guia Consumer Offset, você pode executar as seguintes operações:
- Para redefinir o deslocamento do consumidor de todas as partições de um único tópico, clique em Reset Consumer Offset na linha que contém o tópico desejado.
- Para redefinir o deslocamento do consumidor de uma única partição de um único tópico, clique em Reset Consumer Offset na linha que contém a partição desejada.
- Para redefinir o deslocamento do consumidor de todas as partições em todos os tópicos, clique em Reset Consumer Offset acima da lista.
- Na caixa de diálogo Reset Consumer Offset exibida, defina os parâmetros consultando Tabela 1.
Tabela 1 Parâmetros para redefinir o deslocamento do consumidor Parâmetro
Descrição
Reset By
Você pode redefinir um deslocamento por:
- Time: redefina o deslocamento para o tempo especificado.
- Offset: redefina o deslocamento para a posição especificada.
Se você redefinir deslocamentos em lotes, eles só poderão ser redefinidos para o tempo especificado.
Time
Defina este parâmetro se Reset By estiver definido como Time.
Selecione um ponto de tempo. Após a conclusão da redefinição, a recuperação começa a partir desse ponto de tempo.
- Earliest: deslocamento mais cedo
- Custom Time Range: um ponto de tempo personalizado
- Latest: último deslocamento
Offset
Defina este parâmetro se Reset By estiver definido como Offset.
Insira um deslocamento, que seja maior ou igual a 0. Depois que a redefinição for concluída, a recuperação será iniciada a partir desse deslocamento.
- Clique em OK.
- Clique em Yes na caixa de diálogo de confirmação. O deslocamento do consumidor é redefinido.
