Kinesis operations
Every Kinesis operation Overcast declares — 23 of 23 implemented — with status, behaviour notes and a link to the AWS API reference for each.
All 23 listed operations are implemented. Back to Kinesis.
Summary
| Category | ✅ Supported | ⚠️ Partial |
|---|---|---|
| General | 22 | 1 |
Endpoints
General
| Operation | Status | Notes | AWS Docs |
|---|---|---|---|
AddTagsToStream | ✅ Supported | docs | |
CreateStream | ✅ Supported | Stream becomes ACTIVE immediately; inline Tags and StreamModeDetails applied at creation, defaulting to PROVISIONED | docs |
DecreaseStreamRetentionPeriod | ✅ Supported | Stores and echoes the new value; does not trim any record now older than the shortened window | docs |
DeleteStream | ✅ Supported | Also removes all stored records | docs |
DescribeStream | ✅ Supported | Pages the Shards list on Limit/ExclusiveStartShardId and reports HasMoreShards | docs |
DescribeStreamSummary | ✅ Supported | Lightweight summary without shard detail | docs |
GetRecords | ✅ Supported | Returns stored records and a valid NextShardIterator; records are never expired by RetentionPeriodHours, so a shard keeps every record for the life of the stream regardless of the configured retention | docs |
GetShardIterator | ✅ Supported | Supports TRIM_HORIZON, LATEST, AT/AFTER_SEQUENCE_NUMBER | docs |
IncreaseStreamRetentionPeriod | ✅ Supported | Stores and echoes the new value from DescribeStream/DescribeStreamSummary; not enforced against stored records (see GetRecords) | docs |
ListShards | ⚠️ Partial | Paginates on MaxResults/NextToken/ExclusiveStartShardId, addressable by StreamName or StreamARN; returns active (open) shards only and ignores ShardFilter | docs |
ListStreams | ✅ Supported | Paginates on Limit/NextToken/ExclusiveStartStreamName and returns StreamSummaries alongside StreamNames | docs |
ListTagsForResource | ✅ Supported | Stream ARNs; the same tag set ListTagsForStream returns | docs |
ListTagsForStream | ✅ Supported | Pages on Limit/ExclusiveStartTagKey and reports HasMoreTags | docs |
MergeShards | ✅ Supported | Closes both parents, creates merged child shard | docs |
PutRecord | ✅ Supported | Routes by partition key hash | docs |
PutRecords | ✅ Supported | Returns FailedRecordCount=0 for all records | docs |
RemoveTagsFromStream | ✅ Supported | docs | |
SplitShard | ✅ Supported | Closes parent, creates two children at NewStartingHashKey | docs |
StartStreamEncryption | ✅ Supported | Stores EncryptionType/KeyId and echoes them from Describe*; records are not actually encrypted at rest | docs |
StopStreamEncryption | ✅ Supported | Resets EncryptionType to NONE and clears KeyId | docs |
TagResource | ✅ Supported | Stream ARNs; consumer ARNs are rejected because consumers are not emulated | docs |
UntagResource | ✅ Supported | Stream ARNs | docs |
UpdateStreamMode | ✅ Supported | Stores StreamModeDetails and echoes it from Describe*; on-demand capacity is not actually enforced | docs |
Related
- Kinesis — quick start, what works, and the differences from AWS
- All service pages