View a markdown version of this page

Sondaggi di Apache Kafka e posizioni di partenza per lo streaming in Lambda - AWS Lambda

Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.

Sondaggi di Apache Kafka e posizioni di partenza per lo streaming in Lambda

Il StartingPosition parametro indica a Lambda quando iniziare a leggere i messaggi dal tuo stream Amazon MSK o Apache Kafka autogestito. È possibile scegliere tra tre opzioni:

  • Ultimo: Lambda inizia a leggere subito dopo il record più recente nell'argomento Kafka.

  • Trim horizon: Lambda inizia a leggere dall'ultimo record non tagliato nell'argomento Kafka. Questo è anche il record più vecchio dell'argomento.

  • Al timestamp: Lambda inizia la lettura da una posizione definita da un timestamp, in secondi temporali Unix. Usa il parametro per specificare il timestamp. StartingPositionTimestamp

Il polling dello stream durante la creazione o l'aggiornamento della mappatura della sorgente di un evento è alla fine coerente:

  • Durante la creazione della mappatura della sorgente degli eventi, potrebbero essere necessari diversi minuti per avviare il polling degli eventi dallo stream.

  • Durante gli aggiornamenti della mappatura dell'origine degli eventi, potrebbero essere necessari fino a 90 secondi per interrompere e riavviare gli eventi di polling dallo stream.

Questo comportamento significa che se si specifica LATEST come posizione iniziale per lo stream, nella mappatura dell'origine degli eventi potrebbero mancare gli eventi durante una creazione o un aggiornamento. Per garantire che nessun evento venga perso, specifica uno TRIM_HORIZON oAT_TIMESTAMP.