Amazon Kinesis
amazonaws · Cloud
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.
Authentication
Sample Requests
Describes the specified Kinesis data stream. This API has been revised. It's highly recommended that you use the DescribeStreamSummary API to get a summarized description of the specified Kinesis data stream and the ListShards API to list the shards in a specified data
Hover any highlighted part to learn what it does
| X-Amz-Target | Kinesis_20131202.DescribeStream |
curl -X POST "https://api.apis.guru/v2/specs/amazonaws.com/kinesis/2013-12-02/#X-Amz-Target=Kinesis_20131202.DescribeStream?Limit=10&ExclusiveStartShardId=example" \ -H "X-Amz-Target: Kinesis_20131202.DescribeStream"
import requests
params = {
"Limit": "10",
"ExclusiveStartShardId": "example"
}
headers = {
"X-Amz-Target": "Kinesis_20131202.DescribeStream"
}
response = requests.post(
"https://api.apis.guru/v2/specs/amazonaws.com/kinesis/2013-12-02/#X-Amz-Target=Kinesis_20131202.DescribeStream",
params=params,
headers=headers,
)
print(response.json())const url = new URL('https://api.apis.guru/v2/specs/amazonaws.com/kinesis/2013-12-02/#X-Amz-Target=Kinesis_20131202.DescribeStream');
url.searchParams.set('Limit', '10');
url.searchParams.set('ExclusiveStartShardId', 'example');
const response = await fetch(url, {
method: 'POST',
headers: {
'X-Amz-Target': 'Kinesis_20131202.DescribeStream'
},
});
const data = await response.json();
console.log(data);package main
import (
"fmt"
"io"
"net/http"
"net/url"
)
func main() {
baseURL, _ := url.Parse("https://api.apis.guru/v2/specs/amazonaws.com/kinesis/2013-12-02/#X-Amz-Target=Kinesis_20131202.DescribeStream")
q := baseURL.Query()
q.Set("Limit", "10")
q.Set("ExclusiveStartShardId", "example")
baseURL.RawQuery = q.Encode()
targetURL := baseURL.String()
req, _ := http.NewRequest("POST", targetURL, nil)
req.Header.Set("X-Amz-Target", "Kinesis_20131202.DescribeStream")
client := &http.Client{}
resp, _ := client.Do(req)
defer resp.Body.Close()
body, _ := io.ReadAll(resp.Body)
fmt.Println(string(body))
}require "net/http"
require "json"
uri = URI("https://api.apis.guru/v2/specs/amazonaws.com/kinesis/2013-12-02/#X-Amz-Target=Kinesis_20131202.DescribeStream")
uri.query = URI.encode_www_form({
"Limit" => "10",
"ExclusiveStartShardId" => "example"
})
http = Net::HTTP.new(uri.host, uri.port)
http.use_ssl = uri.scheme == "https"
req = Net::HTTP::Post.new(uri)
req["X-Amz-Target"] = "Kinesis_20131202.DescribeStream"
res = http.request(req)
puts JSON.parse(res.body)<?php
$url = "https://api.apis.guru/v2/specs/amazonaws.com/kinesis/2013-12-02/#X-Amz-Target=Kinesis_20131202.DescribeStream?" . http_build_query([
"Limit" => "10",
"ExclusiveStartShardId" => "example"
]);
$opts = ["http" => [
"method" => "POST",
"header" => implode("\r\n", [
"X-Amz-Target: Kinesis_20131202.DescribeStream"
]),
]];
$ctx = stream_context_create($opts);
$res = file_get_contents($url, false, $ctx);
print_r(json_decode($res, true));Lists the consumers registered to receive data from a stream using enhanced fan-out, and provides information about each consumer. This operation has a limit of 5 transactions per second per stream.
Hover any highlighted part to learn what it does
| X-Amz-Target | Kinesis_20131202.ListStreamConsumers |
curl -X POST "https://api.apis.guru/v2/specs/amazonaws.com/kinesis/2013-12-02/#X-Amz-Target=Kinesis_20131202.ListStreamConsumers?NextToken=example&MaxResults=example" \ -H "X-Amz-Target: Kinesis_20131202.ListStreamConsumers"
import requests
params = {
"NextToken": "example",
"MaxResults": "example"
}
headers = {
"X-Amz-Target": "Kinesis_20131202.ListStreamConsumers"
}
response = requests.post(
"https://api.apis.guru/v2/specs/amazonaws.com/kinesis/2013-12-02/#X-Amz-Target=Kinesis_20131202.ListStreamConsumers",
params=params,
headers=headers,
)
print(response.json())const url = new URL('https://api.apis.guru/v2/specs/amazonaws.com/kinesis/2013-12-02/#X-Amz-Target=Kinesis_20131202.ListStreamConsumers');
url.searchParams.set('NextToken', 'example');
url.searchParams.set('MaxResults', 'example');
const response = await fetch(url, {
method: 'POST',
headers: {
'X-Amz-Target': 'Kinesis_20131202.ListStreamConsumers'
},
});
const data = await response.json();
console.log(data);package main
import (
"fmt"
"io"
"net/http"
"net/url"
)
func main() {
baseURL, _ := url.Parse("https://api.apis.guru/v2/specs/amazonaws.com/kinesis/2013-12-02/#X-Amz-Target=Kinesis_20131202.ListStreamConsumers")
q := baseURL.Query()
q.Set("NextToken", "example")
q.Set("MaxResults", "example")
baseURL.RawQuery = q.Encode()
targetURL := baseURL.String()
req, _ := http.NewRequest("POST", targetURL, nil)
req.Header.Set("X-Amz-Target", "Kinesis_20131202.ListStreamConsumers")
client := &http.Client{}
resp, _ := client.Do(req)
defer resp.Body.Close()
body, _ := io.ReadAll(resp.Body)
fmt.Println(string(body))
}require "net/http"
require "json"
uri = URI("https://api.apis.guru/v2/specs/amazonaws.com/kinesis/2013-12-02/#X-Amz-Target=Kinesis_20131202.ListStreamConsumers")
uri.query = URI.encode_www_form({
"NextToken" => "example",
"MaxResults" => "example"
})
http = Net::HTTP.new(uri.host, uri.port)
http.use_ssl = uri.scheme == "https"
req = Net::HTTP::Post.new(uri)
req["X-Amz-Target"] = "Kinesis_20131202.ListStreamConsumers"
res = http.request(req)
puts JSON.parse(res.body)<?php
$url = "https://api.apis.guru/v2/specs/amazonaws.com/kinesis/2013-12-02/#X-Amz-Target=Kinesis_20131202.ListStreamConsumers?" . http_build_query([
"NextToken" => "example",
"MaxResults" => "example"
]);
$opts = ["http" => [
"method" => "POST",
"header" => implode("\r\n", [
"X-Amz-Target: Kinesis_20131202.ListStreamConsumers"
]),
]];
$ctx = stream_context_create($opts);
$res = file_get_contents($url, false, $ctx);
print_r(json_decode($res, true));Lists your Kinesis data streams. The number of streams may be too large to return from a single call to ListStreams . You can limit the number of returned streams using the Limit parameter. If you do not specify a value for the Limit parameter, Kinesis
Hover any highlighted part to learn what it does
| X-Amz-Target | Kinesis_20131202.ListStreams |
curl -X POST "https://api.apis.guru/v2/specs/amazonaws.com/kinesis/2013-12-02/#X-Amz-Target=Kinesis_20131202.ListStreams?Limit=10&NextToken=example" \ -H "X-Amz-Target: Kinesis_20131202.ListStreams"
import requests
params = {
"Limit": "10",
"NextToken": "example"
}
headers = {
"X-Amz-Target": "Kinesis_20131202.ListStreams"
}
response = requests.post(
"https://api.apis.guru/v2/specs/amazonaws.com/kinesis/2013-12-02/#X-Amz-Target=Kinesis_20131202.ListStreams",
params=params,
headers=headers,
)
print(response.json())const url = new URL('https://api.apis.guru/v2/specs/amazonaws.com/kinesis/2013-12-02/#X-Amz-Target=Kinesis_20131202.ListStreams');
url.searchParams.set('Limit', '10');
url.searchParams.set('NextToken', 'example');
const response = await fetch(url, {
method: 'POST',
headers: {
'X-Amz-Target': 'Kinesis_20131202.ListStreams'
},
});
const data = await response.json();
console.log(data);package main
import (
"fmt"
"io"
"net/http"
"net/url"
)
func main() {
baseURL, _ := url.Parse("https://api.apis.guru/v2/specs/amazonaws.com/kinesis/2013-12-02/#X-Amz-Target=Kinesis_20131202.ListStreams")
q := baseURL.Query()
q.Set("Limit", "10")
q.Set("NextToken", "example")
baseURL.RawQuery = q.Encode()
targetURL := baseURL.String()
req, _ := http.NewRequest("POST", targetURL, nil)
req.Header.Set("X-Amz-Target", "Kinesis_20131202.ListStreams")
client := &http.Client{}
resp, _ := client.Do(req)
defer resp.Body.Close()
body, _ := io.ReadAll(resp.Body)
fmt.Println(string(body))
}require "net/http"
require "json"
uri = URI("https://api.apis.guru/v2/specs/amazonaws.com/kinesis/2013-12-02/#X-Amz-Target=Kinesis_20131202.ListStreams")
uri.query = URI.encode_www_form({
"Limit" => "10",
"NextToken" => "example"
})
http = Net::HTTP.new(uri.host, uri.port)
http.use_ssl = uri.scheme == "https"
req = Net::HTTP::Post.new(uri)
req["X-Amz-Target"] = "Kinesis_20131202.ListStreams"
res = http.request(req)
puts JSON.parse(res.body)<?php
$url = "https://api.apis.guru/v2/specs/amazonaws.com/kinesis/2013-12-02/#X-Amz-Target=Kinesis_20131202.ListStreams?" . http_build_query([
"Limit" => "10",
"NextToken" => "example"
]);
$opts = ["http" => [
"method" => "POST",
"header" => implode("\r\n", [
"X-Amz-Target: Kinesis_20131202.ListStreams"
]),
]];
$ctx = stream_context_create($opts);
$res = file_get_contents($url, false, $ctx);
print_r(json_decode($res, true));Postman Setup Guide
- See official documentation for authentication and setup.
What can you build with Amazon Kinesis?
Amazon Kinesis is a Cloud API. Developers commonly use cloud APIs for:
- provisioning and managing cloud infrastructure
- automating deployments and container orchestration
- monitoring uptime and performance metrics
- managing storage buckets and databases
- setting up auto-scaling and load balancing
No authentication required. This API is open — no signup or key needed. Ideal for quick prototypes and public-facing features. Amazon Kinesis is free to use, making it a low-risk choice to experiment with.
New to APIs? Read our beginner's guide