Fix ContinuationSequenceNumber in SubscribeToShard

nigel-rook-happening · nigel-rook-happening · commit 950217cee340 · 2025-08-08T17:20:23.000+01:00
diff --git a/localstack-core/localstack/services/kinesis/provider.py b/localstack-core/localstack/services/kinesis/provider.py
@@ -125,7 +125,10 @@ def event_generator():
                     raise
                 shard_iterator = result.get("NextShardIterator")
                 records = result.get("Records", [])
-                if not records:
+                if records:
+                    # Update the last sequence number to the last record's sequence number
+                    last_sequence_number = records[-1].get("SequenceNumber", last_sequence_number)
+                else:
                     # On AWS there is *at least* 1 event every 5 seconds
                     # but this is not possible in this structure.
                     # In order to avoid a 5-second blocking call, we make the compromise of 3 seconds.
