Kinesis
Data streams, shards, records, enhanced-fanout consumers.
Quick start
import boto3
kin = boto3.client("kinesis", endpoint_url="http://localhost:4566",
region_name="us-east-1",
aws_access_key_id="test", aws_secret_access_key="test")
kin.create_stream(StreamName="s", ShardCount=1)
kin.put_record(StreamName="s", Data=b"hello", PartitionKey="k")
Supported operations
26 operations exposed by this service as of MiniStack 1.3.14. Extracted directly from the handler dispatch in the source module.
AddTagsToStream
CreateStream
DecreaseStreamRetentionPeriod
DeleteStream
DeregisterStreamConsumer
DescribeStream
DescribeStreamConsumer
DescribeStreamSummary
DisableEnhancedMonitoring
EnableEnhancedMonitoring
GetRecords
GetShardIterator
IncreaseStreamRetentionPeriod
ListShards
ListStreamConsumers
ListStreams
ListTagsForStream
MergeShards
PutRecord
PutRecords
RegisterStreamConsumer
RemoveTagsFromStream
SplitShard
StartStreamEncryption
StopStreamEncryption
UpdateShardCount
CloudFormation
The CloudFormation engine provisions these resource types via this service:
AWS::Kinesis::Stream
See CloudFormation engine for intrinsic support and lifecycle details.
Known limitations
- Shard-level metrics and iterator ages are not tracked.
- Enhanced monitoring settings are stored but not applied.
Source
ministack/services/kinesis.py:174-234
Read the source to verify the ops list above — dispatch tables and handler functions are the ground truth.