Skip to main content

⚠️ DEPRECATED

This package (awslabs.kinesis-mcp-server) is deprecated and no longer maintained.

Please use the official, actively maintained AWS MCP Servers instead: https://github.com/awslabs/mcp

This repository will be archived and its published packages yanked once adequate migration time has passed. No further updates or fixes will be made here.

AWS Labs Kinesis MCP Server

The official MCP Server for interacting with AWS Kinesis

Available MCP Tools

Read Only Operations

  • describe_limits - Describes the limits for a Kinesis data stream in the specified region.
  • describe_stream - Describes the specified stream.
  • describe_stream_consumer - Describes a Kinesis data stream consumer.
  • describe_stream_summary - Describes the stream summary.
  • get_records - Retrieves records from a Kinesis shard.
  • get_resource_policy - Retrieves the resource policy for a Kinesis data stream.
  • get_shard_iterator - Retrieves a shard iterator for a specified shard.
  • list_tags_for_resource - Lists the tags associated with a Kinesis data stream.
  • list_shards - Lists the shards in a Kinesis data stream.
  • list_stream_consumers - Lists the consumers of a Kinesis data stream.
  • list_streams - Lists the Kinesis data streams.

Non Read Only Operations (requires KINESIS-READONLY flag to be set to false)

  • create_stream - Creates a new Kinesis data stream with the specified name and shard count.
  • decrease_stream_retention_period - Decreases the retention period of a Kinesis data stream.
  • delete_resource_policy - Deletes the resource policy for a Kinesis data stream.
  • delete_stream - Deletes a Kinesis data stream.
  • deregister_stream_consumer - Deregisters a consumer from a Kinesis data stream.
  • disable_enhanced_monitoring - Disables enhanced monitoring for a Kinesis data stream.
  • enable_enhanced_monitoring - Enables enhanced monitoring for a Kinesis data stream.
  • increase_stream_retention_period - Increases the retention period of a Kinesis data stream.
  • merge_shards - Merges two adjacent shards in a Kinesis data stream.
  • put_record - Writes a single data record into a Kinesis data stream.
  • put_records - Writes multiple data records to a Kinesis data stream in a single call.
  • put_resource_policy - Attaches a resource policy to a Kinesis data stream.
  • register_stream_consumer - Registers a consumer with a Kinesis data stream.
  • split_shard - Splits a shard into two shards in a Kinesis data stream.
  • start_stream_encryption - Starts encryption for a Kinesis data stream.
  • stop_stream_encryption - Stops encryption for a Kinesis data stream.
  • update_shard_count - Updates the shard count of a Kinesis data stream.
  • update_stream_mode - Updates the mode of a Kinesis data stream.

Instructions

The official MCP Server for interacting with AWS Kinesis provides a comprehensive set of tools for managing Kinesis resources. Each tool maps directly to Kinesis API operations and supports all relevant parameters.

To use these tools, ensure you have proper AWS credentials configured with appropriate permissions for Kinesis operations. The server will automatically use credentials from environment variables (AWS_ACCESS_KEY_ID, AWS_SECRET_ACCESS_KEY, AWS_SESSION_TOKEN) or other standard AWS credential sources.

All tools support an optional region_name parameter to specify which AWS region to operate in. If not provided, it will use the AWS_REGION environment variable or default to 'us-west-2'.

IMPORTANT: If you want to have access to non read only tools, you must set the flag in KINESIS-READONLY to false. The default setup will have this flag set to true.

Prerequisites

  1. Install uv from Astral or the Github README
  2. Install Python using uv python install 3.10
  3. Set up AWS credentials with access to AWS services

Installation

Add the MCP to your favorite agentic tools. e.g. for Amazon Q Developer CLI MCP, ~/.aws/amazonq/mcp.json:

{
  "mcpServers": {
    "awslabs.kinesis-mcp-server": {
      "command": "uvx",
      "args": ["awslabs.kinesis-mcp-server@latest"],
      "env": {
        "KINESIS-READONLY": "true",
      },
      "disabled": false,
      "autoApprove": []
    }
  }
}

or after a successful docker build -t awslabs/kinesis-mcp-server .:

{
    "mcpServers": {
      "awslabs.kinesis-mcp-server": {
        "command": "docker",
        "args": [
          "run",
          "--rm",
          "--interactive",
          "--env",
          "KINESIS-READONLY=true",
          "awslabs/kinesis-mcp-server:latest"
        ],
        "env": {},
        "disabled": false,
        "autoApprove": []
      }
    }
  }

Quick Installation

Run the installation script:

curl -sSL https://raw.githubusercontent.com/jbrub/mcp/main/src/kinesis-mcp-server/install.sh | bash

Metadata

Release files for awslabs.kinesis-mcp-server 0.1.3

For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.

Source distribution (sdist)

Source distribution for awslabs.kinesis-mcp-server 0.1.3
File Size Uploaded
awslabs_kinesis_mcp_server-0.1.3.tar.gz 93.5 kB Details

Built distribution (wheel)

Table of built distributions (wheels) for awslabs.kinesis-mcp-server 0.1.3
File Interpreter ABI Platform
awslabs_kinesis_mcp_server-0.1.3-py3-none-any.whl Python 3 none any Details

Total release size: 114.8 kB

Release files / awslabs_kinesis_mcp_server-0.1.3.tar.gz

Download URL awslabs_kinesis_mcp_server-0.1.3.tar.gz
Size 93.5 kB
Tags Source
SHA-256 checksum
How to use checksums
df4dd6f4d4ad3c92427d1ed68a543dfcfa21a907f06cf235f49b4e28f09b3b32
BLAKE2b-256 checksum
How to use checksums
b15946b672162b22d5cf740d3e9b2b0270ba71ac82632f2c07a2d365c0695c2b
Upload date
Uploaded using Trusted Publishing?
What is trusted publishing?
No
Uploaded via twine/7.0.0 CPython/3.10.21

Release files / awslabs_kinesis_mcp_server-0.1.3-py3-none-any.whl

Download URL awslabs_kinesis_mcp_server-0.1.3-py3-none-any.whl
Size 21.3 kB
Tags Python 3
SHA-256 checksum
How to use checksums
f405db80e0dc3317a8d05498f9ef2d430089aa47c72cc1d878f79fef2015d7d2
BLAKE2b-256 checksum
How to use checksums
30a7425b67e3b1a4332dfe55e58b6cc0f6f9708ebd8fb0c6242ff7290fc15c6b
Upload date
Uploaded using Trusted Publishing?
What is trusted publishing?
No
Uploaded via twine/7.0.0 CPython/3.10.21

Release history Release notifications | RSS feed

This release

0.1.3 This release

2 release files

0.1.2

2 release files

0.1.1

2 release files

0.1.0

2 release files

Anthropic, PBC Visionary sponsor Bloomberg Visionary sponsor Hudson River Trading Visionary sponsor Meta Visionary sponsor NVIDIA Visionary sponsor Microsoft Sustainability sponsor Depot Continuous Integration AWS Cloud computing and Security Sponsor Datadog Monitoring Fastly CDN Google Download Analytics Sentry Error logging StatusPage Status page