Jump to Content

This API Documentation is now deprecated

We are excited to announce our new API Documentation.

@aws-sdk/client-kinesis

Amazon Kinesis Data Streams Service API Reference

Amazon Kinesis Data Streams is a managed service that scales elastically for real-time processing of streaming big data.

Index

Namespaces

SubscribeToShardEventStream

Enumerations

ConsumerStatus EncryptionType MetricsName ScalingType ShardFilterType ShardIteratorType StreamMode StreamStatus

Classes

AccessDeniedException AddTagsToStreamCommand CreateStreamCommand DecreaseStreamRetentionPeriodCommand DeleteStreamCommand DeregisterStreamConsumerCommand DescribeLimitsCommand DescribeStreamCommand DescribeStreamConsumerCommand DescribeStreamSummaryCommand DisableEnhancedMonitoringCommand EnableEnhancedMonitoringCommand ExpiredIteratorException ExpiredNextTokenException GetRecordsCommand GetShardIteratorCommand IncreaseStreamRetentionPeriodCommand InternalFailureException InvalidArgumentException KMSAccessDeniedException KMSDisabledException KMSInvalidStateException KMSNotFoundException KMSOptInRequired KMSThrottlingException Kinesis KinesisClient KinesisServiceException LimitExceededException ListShardsCommand ListStreamConsumersCommand ListStreamsCommand ListTagsForStreamCommand MergeShardsCommand ProvisionedThroughputExceededException PutRecordCommand PutRecordsCommand RegisterStreamConsumerCommand RemoveTagsFromStreamCommand ResourceInUseException ResourceNotFoundException SplitShardCommand StartStreamEncryptionCommand StopStreamEncryptionCommand SubscribeToShardCommand UpdateShardCountCommand UpdateStreamModeCommand ValidationException

Interfaces

AddTagsToStreamCommandInput AddTagsToStreamCommandOutput AddTagsToStreamInput ChildShard ClientDefaults ClientInputEndpointParameters Consumer ConsumerDescription CreateStreamCommandInput CreateStreamCommandOutput CreateStreamInput DecreaseStreamRetentionPeriodCommandInput DecreaseStreamRetentionPeriodCommandOutput DecreaseStreamRetentionPeriodInput DeleteStreamCommandInput DeleteStreamCommandOutput DeleteStreamInput DeregisterStreamConsumerCommandInput DeregisterStreamConsumerCommandOutput DeregisterStreamConsumerInput DescribeLimitsCommandInput DescribeLimitsCommandOutput DescribeLimitsInput DescribeLimitsOutput DescribeStreamCommandInput DescribeStreamCommandOutput DescribeStreamConsumerCommandInput DescribeStreamConsumerCommandOutput DescribeStreamConsumerInput DescribeStreamConsumerOutput DescribeStreamInput DescribeStreamOutput DescribeStreamSummaryCommandInput DescribeStreamSummaryCommandOutput DescribeStreamSummaryInput DescribeStreamSummaryOutput DisableEnhancedMonitoringCommandInput DisableEnhancedMonitoringCommandOutput DisableEnhancedMonitoringInput EnableEnhancedMonitoringCommandInput EnableEnhancedMonitoringCommandOutput EnableEnhancedMonitoringInput EnhancedMetrics EnhancedMonitoringOutput GetRecordsCommandInput GetRecordsCommandOutput GetRecordsInput GetRecordsOutput GetShardIteratorCommandInput GetShardIteratorCommandOutput GetShardIteratorInput GetShardIteratorOutput HashKeyRange IncreaseStreamRetentionPeriodCommandInput IncreaseStreamRetentionPeriodCommandOutput IncreaseStreamRetentionPeriodInput KinesisClientConfig KinesisClientResolvedConfig KinesisPaginationConfiguration ListShardsCommandInput ListShardsCommandOutput ListShardsInput ListShardsOutput ListStreamConsumersCommandInput ListStreamConsumersCommandOutput ListStreamConsumersInput ListStreamConsumersOutput ListStreamsCommandInput ListStreamsCommandOutput ListStreamsInput ListStreamsOutput ListTagsForStreamCommandInput ListTagsForStreamCommandOutput ListTagsForStreamInput ListTagsForStreamOutput MergeShardsCommandInput MergeShardsCommandOutput MergeShardsInput PutRecordCommandInput PutRecordCommandOutput PutRecordInput PutRecordOutput PutRecordsCommandInput PutRecordsCommandOutput PutRecordsInput PutRecordsOutput PutRecordsRequestEntry PutRecordsResultEntry RegisterStreamConsumerCommandInput RegisterStreamConsumerCommandOutput RegisterStreamConsumerInput RegisterStreamConsumerOutput RemoveTagsFromStreamCommandInput RemoveTagsFromStreamCommandOutput RemoveTagsFromStreamInput SequenceNumberRange Shard ShardFilter SplitShardCommandInput SplitShardCommandOutput SplitShardInput StartStreamEncryptionCommandInput StartStreamEncryptionCommandOutput StartStreamEncryptionInput StartingPosition StopStreamEncryptionCommandInput StopStreamEncryptionCommandOutput StopStreamEncryptionInput StreamDescription StreamDescriptionSummary StreamModeDetails StreamSummary SubscribeToShardCommandInput SubscribeToShardCommandOutput SubscribeToShardEvent SubscribeToShardInput SubscribeToShardOutput Tag UpdateShardCountCommandInput UpdateShardCountCommandOutput UpdateShardCountInput UpdateShardCountOutput UpdateStreamModeCommandInput UpdateStreamModeCommandOutput UpdateStreamModeInput _Record

Type Aliases

KinesisClientConfigType KinesisClientResolvedConfigType ServiceInputTypes ServiceOutputTypes SubscribeToShardEventStream

Functions

paginateListStreamConsumers paginateListStreams waitForStreamExists waitForStreamNotExists waitUntilStreamExists waitUntilStreamNotExists

SDK - Clients

Kinesis KinesisClient

SDK - Commands

AddTagsToStreamCommand AddTagsToStreamCommandInput AddTagsToStreamCommandOutput CreateStreamCommand CreateStreamCommandInput CreateStreamCommandOutput DecreaseStreamRetentionPeriodCommand DecreaseStreamRetentionPeriodCommandInput DecreaseStreamRetentionPeriodCommandOutput DeleteStreamCommand DeleteStreamCommandInput DeleteStreamCommandOutput DeregisterStreamConsumerCommand DeregisterStreamConsumerCommandInput DeregisterStreamConsumerCommandOutput DescribeLimitsCommand DescribeLimitsCommandInput DescribeLimitsCommandOutput DescribeStreamCommand DescribeStreamCommandInput DescribeStreamCommandOutput DescribeStreamConsumerCommand DescribeStreamConsumerCommandInput DescribeStreamConsumerCommandOutput DescribeStreamSummaryCommand DescribeStreamSummaryCommandInput DescribeStreamSummaryCommandOutput DisableEnhancedMonitoringCommand DisableEnhancedMonitoringCommandInput DisableEnhancedMonitoringCommandOutput EnableEnhancedMonitoringCommand EnableEnhancedMonitoringCommandInput EnableEnhancedMonitoringCommandOutput GetRecordsCommand GetRecordsCommandInput GetRecordsCommandOutput GetShardIteratorCommand GetShardIteratorCommandInput GetShardIteratorCommandOutput IncreaseStreamRetentionPeriodCommand IncreaseStreamRetentionPeriodCommandInput IncreaseStreamRetentionPeriodCommandOutput ListShardsCommand ListShardsCommandInput ListShardsCommandOutput ListStreamConsumersCommand ListStreamConsumersCommandInput ListStreamConsumersCommandOutput ListStreamsCommand ListStreamsCommandInput ListStreamsCommandOutput ListTagsForStreamCommand ListTagsForStreamCommandInput ListTagsForStreamCommandOutput MergeShardsCommand MergeShardsCommandInput MergeShardsCommandOutput PutRecordCommand PutRecordCommandInput PutRecordCommandOutput PutRecordsCommand PutRecordsCommandInput PutRecordsCommandOutput RegisterStreamConsumerCommand RegisterStreamConsumerCommandInput RegisterStreamConsumerCommandOutput RemoveTagsFromStreamCommand RemoveTagsFromStreamCommandInput RemoveTagsFromStreamCommandOutput SplitShardCommand SplitShardCommandInput SplitShardCommandOutput StartStreamEncryptionCommand StartStreamEncryptionCommandInput StartStreamEncryptionCommandOutput StopStreamEncryptionCommand StopStreamEncryptionCommandInput StopStreamEncryptionCommandOutput SubscribeToShardCommand SubscribeToShardCommandInput SubscribeToShardCommandOutput UpdateShardCountCommand UpdateShardCountCommandInput UpdateShardCountCommandOutput UpdateStreamModeCommand UpdateStreamModeCommandInput UpdateStreamModeCommandOutput

SDK - Paginators

paginateListStreamConsumers paginateListStreams

SDK - Waiters

waitForStreamExists waitForStreamNotExists

Settings

Member Visibility

Theme