Exibição de logs de rebalanceamento
Cenário
Os logs de rebalanceamento registram detalhes de rebalanceamento, incluindo a hora, o motivo e o acionador do cliente de rebalanceamento. Esta seção descreve como exibir logs de rebalanceamento no console.
Os logs de rebalanceamento são armazenados e podem ser consultados no Log Tank Service (LTS).
O que é rebalanceamento?
Rebalanceamento é realocar relacionamentos de assinatura entre consumidores e partições de tópicos em um grupo de consumidores. Durante o rebalanceamento, todos os consumidores do grupo de consumidores param de consumir mensagens até que o rebalanceamento seja concluído.
Possíveis causas do rebalanceamento:
- O número de membros do grupo de consumidores é alterado. Por exemplo, um novo consumidor entra no grupo ou um consumidor sai do grupo.
- O número de tópicos inscritos por um grupo de consumidores é alterado.
- O número de partições de tópico inscritas por um grupo de consumidores é alterado.
Restrições
- Registro em logs de rebalanceamento é desativado automaticamente quando você dimensiona a instância. Se quiser continuar a usá-lo, ative-o novamente.
- Registrar em logs de rebalanceamento não está disponível para instâncias criadas antes de 6 de abril de 2023.
- Por padrão, os logs de rebalanceamento são mantidos por 7 dias. Para armazenar os logs por mais tempo, modifique o período de retenção do grupo de logs no console do LTS.
- Ativar registro em logs de rebalanceamento criará um grupo de log, fluxo de log e painel no LTS. As taxas são geradas com base no volume de log. Para obter detalhes, consulte Detalhes de preços do LTS.
Pré-requisitos
- Certifique-se de que você tem permissões para criar grupos de log e fluxos de log no LTS.
- Registrar em logs de rebalanceamento pode ser ativado ou desativado somente quando a instância de Kafka está no estado Running.
Ativar o registrar em logs de rebalanceamento
- 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á.
- 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 Rebalancing Logs.
- Clique em Enable Logging. Se a mensagem "Rebalancing logging enabled" for exibida no canto superior direito da página, a função de registo de reequilíbrio será ativada com êxito.
Ativar o log de rebalanceamento criará um grupo de log e um fluxo de log no LTS.
Exibição de logs de rebalanceamento
- 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á.
- 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 Rebalancing Logs.
- Na página de guia Dashboard, exiba o número de vezes e motivos de reequilíbrio do grupo de consumidores. Na página da guia Logs, visualize logs de rebalanceamento.
Para obter detalhes sobre como pesquisar logs, consulte Pesquisa de log.
Um exemplo de log de rebalanceamento:
{ "level":"INFO", "timestamp":"2023-03-23 17:23:22,906", "message":{ "leaderId":"consumer-1-177817b6-1f29-4717-8a83-dda8eaab1635", "generationId":"1", "reason":"Assignment received from leader for group KMOffsetCache-dms-vm-fa3cf9d6-manager-shared-server-0 for generation 1", "groupId":"KMOffsetCache-dms-vm-fa3cf9d6-manager-shared-server-0", "coordinatorId":"0", "type":"END_REBALANCE", "group":"GroupMetadata(groupId=KMOffsetCache-dms-vm-fa3cf9d6-manager-shared-server-0, generation=1, protocolType=Some(consumer), currentState=CompletingRebalance, members=Map(consumer-1-177817b6-1f29-4717-8a83-dda8eaab1635 -> MemberMetadata(memberId=consumer-1-177817b6-1f29-4717-8a83-dda8eaab1635, clientId=consumer-1, clientHost=/172.31.2.168, sessionTimeoutMs=10000, rebalanceTimeoutMs=300000, supportedProtocols=List(range), )))" } }
A Tabela 1 descreve os parâmetros.
Tabela 1 Parâmetros de rebalanceamento Parâmetro
Descrição
level
Nível do log de rebalanceamento.
timestamp
Tempo de rebalanceamento.
leaderId
ID do consumidor líder.
generationId
ID de geração do grupo de consumidores. Geração é o número de vezes que um grupo de consumidores executa o rebalanceamento. É incrementado em 1 cada vez que um rebalanceamento é concluído.
reason
Razão para desencadear o rebalanceamento.
groupId
ID do grupo de consumidores.
coordinatorId
Broker onde está o componente Coordinator.
type
Operação que acionou o rebalanceamento.
group
Informações sobre os consumidores no grupo de consumidores.
Desativar o registro em logs de rebalanceamento
- 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á.
- 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 Rebalancing Logs.
- No canto superior direito da página, clique em Disable Logging. Na caixa de diálogo exibida, clique em OK.
Isso só desativa a função de registro em logs de rebalanceamento. Os grupos de logs e os fluxos de logs no LTS são retidos e ainda geram taxas. Se você não precisar mais dos logs, exclua log groups e log streams no LTS.