Change Tracking permite crear grupos de consumidores. Al crear varios grupos de consumidores, puede consumir datos de la misma fuente de forma repetida, lo que reduce el costo de uso de Change Tracking.
Requisitos previos
Debe haber creado una instancia de change tracking y su estado debe ser Normal. Para obtener más información, consulte Descripción general de los escenarios de change tracking.
Notas de uso
Si una sola fila de datos por consumir supera los 16 MB, el cliente consumidor podría experimentar un error de memoria insuficiente (OOM).
Puede crear un máximo de 20 grupos de consumidores para una instancia de change tracking con el fin de permitir el consumo repetido de datos.
Cada grupo de consumidores admite solo un consumidor, y dicho consumidor procesa todos los datos del grupo.
Cambiar el módulo DStore o el cliente puede provocar la duplicación de datos.
Procedimiento
-
Utilice uno de los siguientes métodos para ir a la página Change Tracking Tasks y seleccione la región donde reside la instancia de change tracking.
Consola de DTS
Inicie sesión en la consola de DTS.
En el panel de navegación izquierdo, haga clic en Change Tracking.
En la esquina superior izquierda de la página, seleccione la región donde reside la instancia de change tracking.
Consola de DMS
NotaLas operaciones reales pueden variar según el modo y el diseño de la consola de DMS. Para obtener más información, consulte Simple mode console y Customize DMS console layout and style.
Inicie sesión en la consola de DMS.
En la barra de navegación superior, pase el puntero sobre .
En la lista desplegable a la derecha de Change Tracking Tasks, seleccione la región donde reside la instancia de change tracking.
Localice la instancia de change tracking deseada y haga clic en su ID de instancia.
En el panel de navegación izquierdo, haga clic en Consume Data.
En la página Consume Data, haga clic en Add Consumer Group en la esquina superior izquierda.
-
En el cuadro de diálogo Add Consumer Group, configure los siguientes parámetros.
Parámetro
Descripción
Consumer Group Name
Se recomienda usar un nombre descriptivo para facilitar su identificación.
Account
Introduzca la cuenta para el grupo de consumidores.
-
El nombre de la cuenta puede contener letras mayúsculas, letras minúsculas, dígitos y guiones bajos (_).
-
El nombre de la cuenta debe tener entre 1 y 16 caracteres.
Password
Introduzca la contraseña de la cuenta.
-
La contraseña debe contener caracteres de como mínimo dos de las siguientes categorías: letras mayúsculas, letras minúsculas, dígitos y caracteres especiales.
-
La contraseña debe tener entre 8 y 32 caracteres.
Confirm Password
Vuelva a introducir la misma contraseña.
-
Haga clic en OK.
Siguientes pasos
Después de agregar el grupo de consumidores, seleccione un método de consumo de datos según el tipo de base de datos de origen y el tipo de cliente consumidor.
|
Método de consumo |
Tipos de base de datos compatibles |
Descripción |
|
PolarDB-X 1.0, DMS LogicDB |
Este método está diseñado para instancias de change tracking cuya base de datos de origen es PolarDB-X 1.0 o DMS LogicDB. Nota
Este es el único método de consumo compatible para instancias de change tracking cuya base de datos de origen es PolarDB-X 1.0 o DMS LogicDB. |
|
|
MySQL, PolarDB for MySQL, PostgreSQL, Oracle, PolarDB (Compatible with Oracle), PolarDB for PostgreSQL, PolarDB-X 2.0 |
Este método es adecuado para la mayoría de los escenarios. Nota
Se recomienda este método para todos los tipos de base de datos compatibles. |
|
|
Adecuado para escenarios que usan el framework de procesamiento de flujos Apache Flink. |
||
|
Recomendado para usuarios que cuentan con su propio cliente Kafka y pueden desarrollar a partir del código fuente. |