Veröffentlicht am: Jun 21, 2023
AWS Lambda unterstützt jetzt das Starten ausgehend von einem bestimmten Zeitstempel, wenn Amazon Managed Streaming für Apache Kafka (MSK) oder selbstverwaltetes Kafka als eine Ereignisquellen verwendet wird. Bisher konnten Zuordnungen von Kafka-Ereignisquellen nur die Startpositionen „Trimmhorizont“ oder „Latest“ haben. Wenn Sie nun von einem Zeitstempel aus starten, können Sie die Verarbeitung von Nachrichten zu einem bestimmten Zeitpunkt beginnen. Dies ist z. B. bei der Notfallwiederherstellung nützlich, wenn Sie einen neuen Verbraucher benötigen, um schnell mit der Verarbeitung zu beginnen, wo Sie zuvor aufgehört haben.
Wenn die Zuordnung einer Kafka-Ereignisquelle so konfiguriert ist, dass sie ausgehend von einem bestimmten Zeitstempel startet, beginnt die Zuordnung der Ereignisquelle mit der Verarbeitung von Nachrichten in einem Thema bei oder mit der ersten Nachricht nach dem angegebenen Zeitstempel. Um dieses Feature zu verwenden, erstellen Sie eine neue Zuordnung einer Kafka-Ereignisquelle, setzen „StartingPosition“ auf AT_TIMESTAMP und legen für „StartingPositionTimestamp“ die gewünschte Startposition fest. „StartingPositionTimestamp“ muss in Unix-Zeitsekunden formatiert werden. Bitte beachten Sie, dass in Kafka die Startposition nur für eine neue Verbrauchergruppe verwendet wird oder wenn eine vorhandene Verbrauchergruppe auf einen ungültigen (abgelaufenen) Offset verweist. Neue Zuordnungen von Kafka-Ereignisquellen generieren eine neue Verbrauchergruppen-ID, wenn sie nicht anderweitig mit einer spezifischen Verbrauchergruppen-ID konfiguriert sind.
Für diesem Feature fallen keine zusätzlichen Gebühren an. Sie zahlen für die Lambda-Aufrufe, die durch die Zuordnung von Ereignisquellen ausgelöst werden, die mit Kafka verbunden ist. Weitere Informationen finden Sie im Lambda-Entwicklerhandbuch für Amazon MSK und Apache Kafka.