Publicado: Jun 21, 2023
Agora, o AWS Lambda oferece suporte a especificar um determinado carimbo de data/hora como início para usar o Amazon Managed Streaming for Apache Kafka (MSK) ou o Self-Managed Kafka como fonte de eventos. Anteriormente, os mapeamentos da origem do evento do Kafka só podiam ter posições iniciais de horizonte de corte ou mais recentes. Agora, especificando um carimbo de data/hora, você pode começar a processar mensagens em um momento preciso. Isso é útil em situações como recuperação de desastres, em que você precisa que um novo consumidor inicie rapidamente o processamento de onde você parou anteriormente.
Quando um mapeamento da origem do evento do Kafka é configurado para começar a partir de um carimbo de data/hora específico, o mapeamento da origem do evento começará a processar mensagens em um tópico a partir da primeira mensagem após o carimbo de data/hora especificado. Para usar esse recurso, crie um novo mapeamento da origem do evento do Kafka, defina StartingPosition como AT_TIMESTAMP e defina StartingPositionTimestamp para a posição inicial desejada. O StartingPositionTimestamp precisa ser formatado em segundos de tempo do Unix. No Kafka, a posição inicial só é usada para um novo grupo de consumidores ou quando um grupo de consumidores existente aponta para um deslocamento inválido (expirado). Os novos mapeamentos da origem do evento do Kafka geram um novo ID de grupo de consumidores quando um ID de grupo de consumidores específico não é especificado.
Não há cobrança adicional por esse recurso. Você paga pelas invocações do Lambda acionadas pelo mapeamento da origem do evento conectado ao Kafka. Para saber mais, consulte o Guia do desenvolvedor do Lambda para Amazon MSK e Apache Kafka.