Está creando una aplicación que ingiere un flujo de datos proporcionados por el usuario. Múltiples procesadores basados en EC2 deben consumir el flujo simultáneamente en tiempo real, y cada procesador debe poder reanudarse sin pérdida de datos después de interrupciones. Se añadirán más procesadores más adelante, y desea minimizar los datos duplicados. ¿Qué solución cumple estos requisitos?

Amazon Kinesis Data Streams es la solución ideal porque permite que múltiples consumidores lean el mismo flujo de datos simultáneamente y en tiempo real. Cada procesador basado en EC2 puede mantener su propio puntero (shard iterator) al flujo, lo que le permite reanudar el procesamiento desde el último punto conocido después de una interrupción sin perder datos. Kinesis Data Streams también soporta la adición de más consumidores (procesadores) en el futuro sin afectar a los existentes y minimiza la duplicación de datos al garantizar que cada registro se entrega al menos una vez a cada consumidor. Amazon SQS es un servicio de colas de mensajes que, por defecto, solo permite que un consumidor reciba y procese un mensaje, lo que dificultaría que múltiples procesadores consumieran el mismo flujo simultáneamente sin lógica adicional. Amazon Kinesis Data Firehose está diseñado para cargar datos en destinos de almacenamiento y análisis, no para permitir el consumo en tiempo real por múltiples aplicaciones. Amazon EventBridge es un bus de eventos sin servidor que se utiliza para construir arquitecturas basadas en eventos, no para ingesta de flujos de datos en tiempo real con múltiples consumidores que necesitan reanudar el procesamiento.