Os grupos de consumidores permitem que vários consumidores independentes rastreiem dados de alteração do mesmo banco de dados de source simultaneamente. Esse recurso reduz o custo de rastreamento de alterações de dados.
Pré-requisitos
Antes de começar, verifique se você tem:
Uma instância de rastreamento de alterações com status Normal. Para mais informações, consulte Visão geral dos cenários de rastreamento de alterações.
Limites
Cada instância de rastreamento de alterações aceita no máximo 20 grupos de consumidores.
Cada grupo de consumidores aceita apenas um consumidor.
Se uma linha rastreada exceder 16 MB, poderá ocorrer um erro de falta de memória (OOM) no cliente de rastreamento de alterações.
O DTS lê dados incrementais pelo módulo DStore ou por um cliente. Alternar entre esses métodos pode causar duplicação de dados.
Crie um grupo de consumidores
-
Acesse a página Change Tracking Tasks por um dos métodos abaixo e selecione a região da instância de rastreamento de alterações.
DTS console
Faça login no console do DTS.
No painel de navegação à esquerda, clique em Change Tracking.
No canto superior esquerdo, selecione a região da instância de rastreamento de alterações.
DMS console
Nota
Os caminhos de navegação no console do DMS variam conforme o modo e o layout do console. Para mais informações, consulte Modo simples e Personalizar o layout e o estilo do console do DMS.
Faça login no console do DMS.
Na barra de navegação superior, escolha Data + AI > DTS (DTS) > Change Tracking.
À direita de Change Tracking Tasks, selecione a região da instância de rastreamento de alterações.
Localize a instância de rastreamento de alterações e clique em ID da instância.
No painel de navegação à esquerda, clique em Consume Data.
Na página Consume Data, clique em Add Consumer Group no canto superior esquerdo.
-
Na caixa de diálogo Add Consumer Group, configure os seguintes parâmetros.
Parâmetro
Descrição
Consumer Group Name
Insira um nome para identificar o grupo de consumidores e sua finalidade.
Account
Defina um nome de usuário para o grupo de consumidores. O nome deve ter de 1 a 16 caracteres e pode conter letras maiúsculas, letras minúsculas, dígitos e sublinhados (_).
Password
Crie uma senha para a conta. A senha deve ter de 8 a 32 caracteres e incluir pelo menos dois dos seguintes elementos: letras maiúsculas, letras minúsculas, dígitos e caracteres especiais.
Confirm Password
Insira a senha novamente para confirme.
Clique em OK.
Próximas etapas
Após criar os grupos de consumidores, escolha um modo de consumo adequado ao tipo do banco de dados de source e ao cliente utilizado.
|
Modo de consumo |
Bancos de dados aplicáveis |
Observações |
|
Usar a demonstração do SDK para consumir dados rastreados de uma instância PolarDB-X 1.0 |
PolarDB-X 1.0, DMS LogicDB |
Único modo de consumo compatível com estes tipos de banco de dados. |
|
MySQL, PolarDB for MySQL, PostgreSQL, Oracle, PolarDB (Compatible with Oracle), PolarDB for PostgreSQL, PolarDB-X 2.0 |
Recomendado para a maioria dos cenários. |
|
|
— |
Use este modo para consumir dados rastreados com Apache Flink. O Apache Flink é um framework e mecanismo de processamento distribuído. |
|
|
— |
Use este modo para consumir dados rastreados com um cliente Kafka e código-fonte personalizado. |