Todos los productos
Search
Centro de documentos

Data Transmission Service:Agregar un grupo de consumidores

Última actualización: Sep 04, 2026

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

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

    1. Inicie sesión en la consola de DTS.

    2. En el panel de navegación izquierdo, haga clic en Change Tracking.

    3. En la esquina superior izquierda de la página, seleccione la región donde reside la instancia de change tracking.

    Consola de DMS

    Nota

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

    1. Inicie sesión en la consola de DMS.

    2. En la barra de navegación superior, pase el puntero sobre Data + AI > DTS (DTS) > Change Tracking.

    3. En la lista desplegable a la derecha de Change Tracking Tasks, seleccione la región donde reside la instancia de change tracking.

  2. Localice la instancia de change tracking deseada y haga clic en su ID de instancia.

  3. En el panel de navegación izquierdo, haga clic en Consume Data.

  4. En la página Consume Data, haga clic en Add Consumer Group en la esquina superior izquierda.

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

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

Consume data from a PolarDB-X 1.0 instance by using an SDK

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.

Consume data by using an SDK

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.

Consume data by using flink-dts-connector

Adecuado para escenarios que usan el framework de procesamiento de flujos Apache Flink.

Consume data by using a Kafka client

Recomendado para usuarios que cuentan con su propio cliente Kafka y pueden desarrollar a partir del código fuente.