Se um consumidor parar de consumir mensagens devido a uma exceção, verifique o último offset de consumidor confirmado e redefina-o se necessário.
Como funciona a confirmação de offsets
O offset de consumidor rastreia a posição da próxima mensagem a ser lida em uma partição. O broker não atualize essa posição automaticamente; ele registra apenas o offset que o consumidor confirma explicitamente.
O método de confirmação depende do SDK do cliente. A maioria dos SDKs oferece dois métodos:
|
Método |
Descrição |
|
Confirmação automática |
O SDK confirma periodicamente o offset da última mensagem consumida mais 1. |
|
Confirmação manual |
Sua aplicação chama |
Ao reiniciar, o consumidor retoma a partir do último offset confirmado. Identificar o método de confirmação usado pela aplicação facilita o diagnóstico de releitura ou perda de mensagens pelo consumidor.
Visualize o offset atual do consumidor
Para visualizar o último offset confirmado de um consumidor:
Abra a página Topic Details do tópico desejado.
Na aba Subscriptions, localize o tópico alvo e clique em Consumer Details na coluna Actions.
No painel exibido, analise o offset de consumidor confirmado. O consumidor retomará o processamento a partir desse offset.
Para obter etapas detalhadas, consulte Visualizar detalhes do consumidor.
Redefina o offset do consumidor
Interrompa todos os consumidores do grupo antes de redefinir o offset. Se algum consumidor ainda estiver em execução, ele poderá confirmar um novo offset e substituir o valor redefinido.
Para redefinir um offset de consumidor:
Acesse a página Group Details do grupo de consumidores desejado.
No canto superior direito, clique em Reset Consumer Offset.
No painel Reset Consumer Offset, selecione um método de redefinição e configure o offset alvo.
Para a lista completa de métodos de redefinição e instruções detalhadas, consulte Redefinir offsets de consumidor.