Redefinição do deslocamento de consumidor

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

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 do Kafka desejada para exibir os detalhes da instância.
5. No painel de navegação, escolha a guia Consumer Groups.
6. Clique no nome do grupo de consumidores desejado.
7. 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.

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

9. Clique em OK.
10. Clique em Yes na caixa de diálogo de confirmação. O deslocamento do consumidor é redefinido.