Ich muss Daten aus einem AWS Kinesis-Stream verarbeiten, der Ereignisse von Geräten erfasst. Die Verarbeitungsfunktion muss jede Sekunde mit allen in den letzten 10 Sekunden empfangenen Ereignissen au
Ich versuche, eine einfache Anwendung zu erstellen, die Daten von AWS Kinesis liest. Ich habe es geschafft, Daten mit einem einzigen Shard zu lesen, aber ich möchte Daten von 4 verschiedenen Shards be
Wie hängen Checkpoints und Trimming in der AWS KCL-Bibliothek zusammen? Die Dokumentation Seite Startup Handhabung, Shutdown und Throttling sagt: standardmäßig die KCL Datensätze aus der Spitze des St