ID del gruppo di consumatori personalizzabile in Lambda

Quando si configura Kafka come fonte di eventi, è possibile specificare un ID del gruppo di consumatori. Questo ID gruppo di consumer è un identificatore esistente per il gruppo di consumer Kafka a cui desideri che la tua funzione Lambda aderisca. Puoi utilizzare questa funzione per migrare senza problemi qualsiasi configurazione di elaborazione dei record Kafka in corso da altri utenti a Lambda.

Kafka distribuisce messaggi a tutti i consumatori di un gruppo di consumatori. Se si specifica un ID di gruppo di consumatori con altri consumatori attivi, Lambda riceve solo una parte dei messaggi dall'argomento Kafka. Se desideri che Lambda gestisca tutti i messaggi nell'argomento, disattiva tutti gli altri consumatori in quel gruppo di consumatori.

Inoltre, se specifichi un ID del gruppo di consumatori e Kafka trova un gruppo di consumatori esistente valido con lo stesso ID, Lambda lo ignora StartingPositionper la mappatura dell'origine dell'evento. Inizia invece ad elaborare i record in base alla compensazione impegnata del gruppo di consumer. Se specifichi un ID gruppo di consumer e Kafka non riesce a trovare un gruppo di consumer esistente, Lambda configura l'origine eventi con la StartingPosition specificata.

L'ID gruppo di consumer deve essere univoco tra tutte le origini eventi Kafka. Dopo aver creato una mappatura dell'origine eventi Kafka con l'ID gruppo di consumer specificato, non sarà più possibile aggiornare questo valore.