Integration

AWS Kinesis integration

Amazon Kinesis Data Streams API for real-time streaming data processing. Create and manage data streams, put and get records, manage shards, and handle consumers for real-time analytics and event processing.

Connect AWS Kinesis How integrations work

Ask it in chat

Say what should happen.
The workflow builds itself.

When this happens, do that in AWS Kinesis.Built from the 39 AWS Kinesis tools below, on the connection you add once.

Common AWS Kinesis use cases

automate stream management
automate stream consumer management
automate tag management
automate shard management
automate record management
automate resource tag management
automate resource policy management
put record programmatically
automate account settings management
automate stream encryption management

What you can do with AWS Kinesis

Each of these is one operation on one endpoint, available both as a workflow step and as a tool an AI agent can call on its own. Nothing bundles several operations into one action, so what a run did stays readable afterwards.

Most endpoints run on the free plan. A few, mainly the ones that publish on your behalf, need a paid plan.

Stream, 4 operations

create_streamCreate streamPOSTCreates a Kinesis data stream. A stream captures and transports data records that are continuously emitted from different data sources or producers.
delete_streamDelete streamPOSTDeletes a Kinesis data stream and all its shards and data. You must shut down any applications that are operating on the stream before you delete the stream.
describe_streamDescribe streamPOSTDescribes the specified Kinesis data stream. Returns the stream description including stream name, ARN, status, and shard list.
list_streamsList streamsPOSTLists your Kinesis data streams. Returns the names of all streams associated with the account and the region.

Stream consumer, 4 operations

deregister_stream_consumerDeregister stream consumerPOSTTo deregister a consumer, provide its ARN. Alternatively, you can provide the ARN of the Kinesis data stream and the name you gave the consumer when you registered it.
describe_stream_consumerDescribe stream consumerPOSTTo get the description of a registered consumer, provide the ARN of the consumer. Alternatively, you can provide the ARN of the data stream and the name of the consumer.
list_stream_consumersList stream consumersPOSTLists the consumers registered to receive data from a stream using enhanced fan-out, and provides information about each consumer.
register_stream_consumerRegister stream consumerPOSTRegisters a consumer with a Kinesis data stream. The consumer can then call SubscribeToShard to receive data from the stream using enhanced fan-out.

Record, 3 operations

get_recordsGet recordsPOSTGets data records from a Kinesis data stream's shard. You must obtain a shard iterator with GetShardIterator before calling GetRecords.
put_recordPut recordPOSTWrites a single data record into an Amazon Kinesis data stream. The partition key is used to determine which shard the record is assigned to.
put_recordsPut recordsPOSTWrites multiple data records into a Kinesis data stream in a single call. Each PutRecords request can support up to 500 records.

Resource policy, 3 operations

delete_resource_policyDelete resource policyPOSTDeletes a policy for the specified data stream or consumer.
get_resource_policyGet resource policyPOSTReturns a policy attached to the specified data stream or consumer.
put_resource_policyPut resource policyPOSTAttaches a resource-based policy to a data stream or registered consumer.

Resource tag, 3 operations

list_tags_for_resourceList tags for resourcePOSTList all tags added to the specified Kinesis resource.
tag_resourceTag resourcePOSTAdds or updates tags for the specified Kinesis resource.
untag_resourceUntag resourcePOSTRemoves tags from the specified Kinesis resource.

Shard, 3 operations

list_shardsList shardsPOSTLists the shards in a stream and provides information about each shard. This operation has a limit of 1000 transactions per second per data stream.
merge_shardsMerge shardsPOSTMerges two adjacent shards in a Kinesis data stream and combines them into a single shard to reduce the stream's capacity to ingest and transport data.
split_shardSplit shardPOSTSplits a shard into two new shards in the Kinesis data stream, to increase the stream's capacity to ingest and transport data.

Tag, 3 operations

add_tags_to_streamAdd tags to streamPOSTAdds or updates tags for the specified Kinesis data stream. A stream can have up to 50 tags.
list_tags_for_streamList tags for streamPOSTLists the tags for the specified Kinesis data stream. This operation has a limit of five transactions per second per account.
remove_tags_from_streamRemove tags from streamPOSTRemoves tags from the specified Kinesis data stream. Removed tags are deleted and cannot be recovered after this operation successfully completes.

Account settings, 2 operations

describe_account_settingsDescribe account settingsPOSTRetrieves the account settings for the specified AWS account.
update_account_settingsUpdate account settingsPOSTUpdates the account settings for the specified AWS account.

Enhanced monitoring, 2 operations

disable_enhanced_monitoringDisable enhanced monitoringPOSTDisables enhanced monitoring (enhanced shard-level metrics) for a Kinesis data stream.
enable_enhanced_monitoringEnable enhanced monitoringPOSTEnables enhanced Kinesis data stream monitoring for shard-level metrics.

Stream encryption, 2 operations

start_stream_encryptionStart stream encryptionPOSTEnables or updates server-side encryption using an AWS KMS key for a specified stream.
stop_stream_encryptionStop stream encryptionPOSTDisables server-side encryption for a specified stream.

Decrease stream retention period, 1 operation

decrease_stream_retention_periodDecrease stream retention periodPOSTDecreases the Kinesis data stream's retention period, which is the length of time data records are accessible after they are added to the stream.

Increase stream retention period, 1 operation

increase_stream_retention_periodIncrease stream retention periodPOSTIncreases the Kinesis data stream's retention period, which is the length of time data records are accessible after they are added to the stream.

Limits, 1 operation

describe_limitsDescribe limitsPOSTDescribes the shard limits and usage for the account.

Max record size, 1 operation

update_max_record_sizeUpdate max record sizePOSTUpdates the maximum record size of a Kinesis data stream.

Shard count, 1 operation

update_shard_countUpdate shard countPOSTUpdates the shard count of the specified stream to the specified number of shards. The default minimum and maximum shard counts are 1 and 10000.

Shard iterator, 1 operation

get_shard_iteratorGet shard iteratorPOSTGets an Amazon Kinesis shard iterator. A shard iterator expires 5 minutes after it is returned to the requester.

Shard subscription, 1 operation

subscribe_to_shardSubscribe to shardPOSTEstablishes an HTTP/2 streaming connection to receive records from a shard via enhanced fan-out as server-sent events.

Stream mode, 1 operation

update_stream_modeUpdate stream modePOSTUpdates the capacity mode of an Amazon Kinesis data stream, switching between ON_DEMAND and PROVISIONED modes.

Stream summary, 1 operation

describe_stream_summaryDescribe stream summaryPOSTProvides a summarized description of the specified Kinesis data stream without the shard list. Returns stream ARN, status, retention period, and consumer count.

Stream warm throughput, 1 operation

update_stream_warm_throughputUpdate stream warm throughputPOSTUpdates the warm throughput configuration of a Kinesis data stream.

Use AWS Kinesis from Claude Code, Cursor or Codex

Connect AWS Kinesis in LiveContext, create an API key in Settings, then add the LiveContext MCP server to your client. Its AWS Kinesis operations become tools the client can call, next to every other integration you connected.

Claude Code

claude mcp add --transport http livecontext https://livecontext.ai/mcp --header "X-API-Key: YOUR_API_KEY"

Codex (~/.codex/config.toml)

[mcp_servers.livecontext]
url = "https://livecontext.ai/mcp"

[mcp_servers.livecontext.http_headers]
"X-API-Key" = "YOUR_API_KEY"

Cursor, Claude Desktop and other JSON configs

{
  "mcpServers": {
    "livecontext": {
      "type": "http",
      "url": "https://livecontext.ai/mcp",
      "headers": {
        "X-API-Key": "YOUR_API_KEY"
      }
    }
  }
}

Set up the MCP server step by step

How to connect AWS Kinesis

Create your workspace
Sign up free. Nothing to install.
Connect AWS Kinesis once
Add your AWS Kinesis connection in Settings. Every tool from this integration reuses it, and secrets are encrypted at rest and visible only to you.
Describe the job in chat
The workflow builds itself in front of you and picks the endpoints it needs. Drag the steps yourself on the canvas whenever you would rather be explicit.

AWS Kinesis integration FAQ

What can you do with the AWS Kinesis integration?

LiveContext exposes 39 operations on AWS Kinesis, covering stream, stream consumer, record and resource policy. Common uses include automate stream management, automate stream consumer management and automate tag management.