Intégrelo KPL con el código del productor - Amazon Kinesis Data Streams

Las traducciones son generadas a través de traducción automática. En caso de conflicto entre la traducción y la version original de inglés, prevalecerá la version en inglés.

Intégrelo KPL con el código del productor

La biblioteca de productores de Kinesis (KPL) se ejecuta en un proceso independiente y se comunica con el proceso de usuario principal mediante. IPC Esta arquitectura se denomina a veces microservicio, y se elige por dos razones principales:

1) Su proceso de usuario no se bloqueará aunque se bloquee KPL

Su proceso podría incluir tareas no relacionadas con Kinesis Data Streams y podría continuar funcionando incluso si KPL el proceso se bloquea. También es posible que su proceso de usuario principal se reinicie KPL y recupere su estado de funcionamiento completo (esta funcionalidad se encuentra en los envoltorios oficiales).

Un ejemplo es un servidor web que envía métricas a Kinesis Data Streams. El servidor puede continuar sirviendo páginas incluso si la parte de Kinesis Data Streams dejó de funcionar. Por lo tanto, si se bloquea todo el servidor debido a un error, se KPL produciría una interrupción innecesaria.

2) Compatibilidad con clientes arbitrarios

Siempre hay consumidores que usan lenguajes diferentes a los que son oficialmente compatibles. Estos clientes también deberían poder usarlo fácilmente. KPL

Matriz de uso recomendado

La siguiente matriz de uso enumera las configuraciones recomendadas para los distintos usuarios y le informa sobre si debe utilizarlas y cómo. KPL Tenga en cuenta que si se habilita la agregación, también debe utilizar desagrupación para extraer sus registros en el lado del consumidor.

Lenguaje del lado del productor Lenguaje del lado del consumidor KCLVersión Lógica del punto de comprobación ¿Puede utilizar la KPL? Advertencias
Cualquiera excepto Java * * * No N/A
Java Java Usa Java SDK directamente N/A Si se utiliza agregación, deberá usar la biblioteca de desagrupación facilitada tras la llamada de GetRecords.
Java Cualquiera excepto Java Usa SDK directamente N/A Debe deshabilitar la agregación.
Java Java 1.3.x N/A Debe deshabilitar la agregación.
Java Java 1.4.x Llama al punto de comprobación sin argumentos Ninguna
Java Java 1.4.x Llama al punto de comprobación con un número secuencial explícito Desactive la agregación o cambie el código para usar números secuenciales ampliados para la creación de puntos de control.
Java Cualquiera excepto Java 1.3.x + daemon multilenguaje + contenedor específico del lenguaje N/A Debe deshabilitar la agregación.