Sondaggi di Apache Kafka e posizioni iniziali dello streaming in Lambda
Il parametro startingPosition indica a Lambda quando iniziare a leggere i messaggi dal tuo stream Amazon MSK o Apache Kafka autogestito. Ci sono tre opzioni tra cui scegliere:
-
Più recente: Lambda inizia a leggere subito dopo il record più recente nell'argomento Kafka.
-
Orizzonte di taglio: inizia a leggere l'argomento con l'ultimo record non tagliato nella partizione. Questo è il record meno recente nella partizione.
-
Al timestamp: Lambda avvia la lettura da una posizione definita da un timestamp, in secondi di tempo Unix. Utilizzate il parametro startingPositionTimestamp per specificare il timestamp.
Tieni presente che il polling dei flussi durante la creazione e gli aggiornamenti dello strumento di mappatura dell'origine degli eventi alla fine è coerente.
-
Durante la creazione dello strumento di mappatura dell'origine degli eventi, potrebbero essere necessari alcuni minuti per l'avvio degli eventi di polling dal flusso.
-
Durante gli aggiornamenti dello strumento di mappatura dell'origine degli eventi, potrebbero essere necessari alcuni minuti per l'avvio degli eventi di polling dal flusso.
Questo comportamento implica che se specifichi LATEST come posizione iniziale del flusso, lo strumento di mappatura dell'origine degli eventi potrebbe perdere eventi durante la creazione o gli aggiornamenti. Per garantire che nessun evento venga perso, specificate o. TRIM_HORIZON AT_TIMESTAMP
