Publicado en: Jun 21, 2023
AWS Lambda ahora permite partir de una marca temporal específica cuando se utiliza Amazon Managed Streaming para Apache Kafka (MSK) o Kafka autoadministrado como origen de eventos. Anteriormente, las asignaciones de orígenes de eventos de Kafka solo podían tener posiciones iniciales de recorte de horizonte o posteriores. Ahora, al iniciar desde una marca temporal, puede empezar a procesar los mensajes en un momento preciso. Esto resulta útil para situaciones como la recuperación de desastres, en las que necesita que un nuevo consumidor comience a procesar rápidamente donde usted dejó anteriormente.
Cuando una asignación de orígenes de eventos de Kafka se configura para que comience desde una marca temporal específica, la asignación de orígenes de eventos comenzará a procesar los mensajes de un tema en la marca temporal especificada o en el primer mensaje después de la marca temporal especificada. Para utilizar esta característica, cree una nueva asignación de orígenes de eventos de Kafka, establezca StartingPosition en AT_TIMESTAMP y establezca StartingPositionTimestamp en la posición inicial deseada. StartingPositionTimeStamp debe formatearse en segundos de Unix. Tenga en cuenta que en Kafka, la posición inicial solo se usa para un nuevo grupo de consumidores o cuando un grupo de consumidores existente señala una compensación que no es válida (caduca). Las nuevas asignaciones de orígenes de eventos de Kafka generarán un nuevo ID de grupo de consumidores si no se configuran de otra manera con un ID de grupo de consumidores específico.
No se aplican cargos adicionales por el uso de esta característica. Usted paga por las invocaciones de Lambda activadas por la asignación de orígenes de eventos conectada a Kafka. Para obtener más información, consulte la Guía para desarrolladores de Lambda para Amazon MSK y Apache Kafka.