Creación de una canalización de Amazon EventBridge

Para configurar una secuencia de Confluent Cloud como fuente, mediante la consola

1. En Origen, elija Confluent Cloud.

2. En Servidores de arranque, introduzca el par de direcciones host:port de sus agentes.

3. En Nombre de tema, introduzca el nombre del tema desde donde leerá la canalización.

4. (Opcional) En VPC, elija el VPC que desee. A continuación, en Subredes de VPC, seleccione las subredes deseadas. En Grupos de seguridad de VPC, seleccione los grupos de seguridad.

5. En Autenticación: opcional, active Usar autenticación y haga lo siguiente:

   1. En Método de autenticación, seleccione el tipo de autenticación.

   2. En Clave secreta, seleccione la clave secreta.

   Para obtener más información, consulte Autenticarse en los recursos de Confluent Cloud en la documentación de Confluent.

6. (Opcional) En Configuración adicional: opcional, haga lo siguiente:

   1. En Posición inicial, seleccione una de las siguientes opciones:

      • Última: comience a leer el flujo con el registro más reciente de la partición.

      • Recortar horizonte: comience a leer el flujo con el último registro sin recortar de la partición. Este es el registro más antiguo de la partición.

   2. En Tamaño de lote: opcional, introduzca un número máximo de registros para cada lote. El valor predeterminado es 100.

   3. En Ventana de lote: opcional, introduzca un número máximo de segundos para recopilar los registros antes de continuar.

1. En Origen, seleccione DynamoDB.

2. En flujo de DynamoDB, seleccione el flujo que desee usar como origen.

3. En Posición inicial, seleccione una de las siguientes opciones:

   • Última: comience a leer el flujo con el registro más reciente de la partición.

   • Recortar horizonte: comience a leer el flujo con el último registro sin recortar de la partición. Este es el registro más antiguo de la partición.

4. (Opcional) En Configuración adicional: opcional, haga lo siguiente:

   1. En Tamaño de lote: opcional, introduzca un número máximo de registros para cada lote. El valor predeterminado es 100.

   2. En Ventana de lote: opcional, introduzca un número máximo de segundos para recopilar los registros antes de continuar.

   3. En Lotes simultáneos por partición: opcional, introduzca el número de lotes de la misma partición que se pueden leer al mismo tiempo.

   4. En Fallo parcial de elementos del lote, seleccione lo siguiente:

      • AUTOMATIC_BISECT: Divide en dos cada lote e intenta volver a enviar cada mitad hasta que se procesan todos los registros o aparece un mensaje de error en el lote.

      nota

      Si no selecciona AUTOMATIC_BISECT, puede devolver determinados registros fallidos y solo se intentará volver a enviar esos registros.

Para configurar un origen de Kinesis con la consola

1. En Origen, seleccione Kinesis.

2. En Flujo de Kinesis, seleccione el flujo que desee usar como origen.

3. En Posición inicial, seleccione una de las siguientes opciones:

   • Última: comience a leer el flujo con el registro más reciente de la partición.

   • Recortar horizonte: comience a leer el flujo con el último registro sin recortar de la partición. Este es el registro más antiguo de la partición.

   • En marca de tiempo: comience a leer el flujo a partir de una hora específica. En Marca de tiempo, introduzca una fecha y una hora con los formatos AAAA/MM/DD y hh:mm:ss.

4. (Opcional) En Configuración adicional: opcional, haga lo siguiente:

   1. En Tamaño de lote: opcional, introduzca un número máximo de registros para cada lote. El valor predeterminado es 100.

   2. (Opcional) En Ventana de lote: opcional, introduzca un número máximo de segundos para recopilar los registros antes de continuar.

   3. En Lotes simultáneos por partición: opcional, introduzca el número de lotes de la misma partición que se pueden leer al mismo tiempo.

   4. En Fallo parcial de elementos del lote, seleccione lo siguiente:

      • AUTOMATIC_BISECT: Divide en dos cada lote e intenta volver a enviar cada mitad hasta que se procesan todos los registros o aparece un mensaje de error en el lote.

      nota

      Si no selecciona AUTOMATIC_BISECT, puede devolver determinados registros fallidos y solo se intentará volver a enviar esos registros.

Para configurar un origen de Amazon MQ con la consola

1. En Tipo de origen, seleccione Amazon MQ.

2. En agente de Amazon MQ, seleccione el flujo que desee usar como origen.

3. En Nombre de cola, introduzca el nombre de la cola desde donde leerá la canalización.

4. En Método de autenticación, seleccione BASIC_AUTH.

5. En Clave secreta, seleccione la clave secreta.

6. (Opcional) En Configuración adicional: opcional, haga lo siguiente:

   1. En Tamaño de lote: opcional, introduzca un número máximo de mensajes para cada lote. El valor predeterminado es 100.

   2. En Ventana de lote: opcional, introduzca un número máximo de segundos para recopilar los registros antes de continuar.

Para configurar un origen de Amazon MSK con la consola

1. En Origen, seleccione Amazon MSK.

2. En Clúster de Amazon MSK, seleccione el clúster que desee usar.

3. En Nombre de tema, introduzca el nombre del tema desde donde leerá la canalización.

4. (Opcional) En ID del grupo de consumidores: opcional, introduzca el ID de un grupo de consumidores al que desea que se una la canalización.

5. (Opcional) En Autenticación: opcional, active Usar autenticación y haga lo siguiente:

   1. En Método de autenticación, seleccione el tipo que desees.

   2. En Clave secreta, seleccione la clave secreta.

6. (Opcional) En Configuración adicional: opcional, haga lo siguiente:

   1. En Tamaño de lote: opcional, introduzca un número máximo de registros para cada lote. El valor predeterminado es 100.

   2. En Ventana de lote: opcional, introduzca un número máximo de segundos para recopilar los registros antes de continuar.

   3. En Posición inicial, seleccione una de las siguientes opciones:

      • Última: comience a leer el tema con el registro más reciente de la partición.

      • Recortar horizonte: comience a leer el tema con el último registro sin recortar de la partición. Este es el registro más antiguo de la partición.

        nota

        Recortar horizonte es lo mismo que Primero para Apache Kafka.

Para configurar una origen de Apache Kafka autogestionado mediante la consola

1. En Origen, seleccione Apache Kafka autogestionado.

2. En Servidores de arranque, introduzca el par de direcciones host:port de sus agentes.

3. En Nombre de tema, introduzca el nombre del tema desde donde leerá la canalización.

4. (Opcional) En VPC, elija el VPC que desee. A continuación, en Subredes de VPC, seleccione las subredes deseadas. En Grupos de seguridad de VPC, seleccione los grupos de seguridad.

5. (Opcional) En Autenticación: opcional, active Usar autenticación y haga lo siguiente:

   1. En Método de autenticación, seleccione el tipo de autenticación.

   2. En Clave secreta, seleccione la clave secreta.

6. (Opcional) En Configuración adicional: opcional, haga lo siguiente:

   1. En Posición inicial, seleccione una de las siguientes opciones:

      • Última: comience a leer el flujo con el registro más reciente de la partición.

      • Recortar horizonte: comience a leer el flujo con el último registro sin recortar de la partición. Este es el registro más antiguo de la partición.

   2. En Tamaño de lote: opcional, introduzca un número máximo de registros para cada lote. El valor predeterminado es 100.

   3. En Ventana de lote: opcional, introduzca un número máximo de segundos para recopilar los registros antes de continuar.

Para configurar un origen de Amazon SQS con la consola

1. En Origen, seleccione SQS.

2. En Cola de SQS, seleccione la cola que desee utilizar.

3. (Opcional) En Configuración adicional: opcional, haga lo siguiente:

   1. En Tamaño de lote: opcional, introduzca un número máximo de registros para cada lote. El valor predeterminado es 100.

   2. En Ventana de lote: opcional, introduzca un número máximo de segundos para recopilar los registros antes de continuar.