Amazon Kinesis Data Streams

Amazon Kinesis Data Streams is a massively scalable and durable real-time data streaming service. It can continuously capture gigabytes of data per second from hundreds of thousands of sources such as website clickstreams, database event streams, financial transactions, social media feeds, IT logs, and location-tracking events.

Documentation

Specifications

Schemas & Data

Other Resources

🔗
JSONLD
https://raw.githubusercontent.com/api-evangelist/amazon-kinesis/refs/heads/main/json-ld/amazon-kinesis-context.jsonld
🔗
OpenAPI (Third-Party)
https://api.apis.guru/v2/specs/amazonaws.com/kinesis/2013-12-02/openapi.yaml
🔗
Pricing
https://aws.amazon.com/kinesis/data-streams/pricing/
🔗
Features
https://aws.amazon.com/kinesis/data-streams/features/
🔗
FAQ
https://aws.amazon.com/kinesis/data-streams/faqs/
🔗
Quotas
https://docs.aws.amazon.com/streams/latest/dev/service-sizes-and-limits.html
🔗
NaftikoCapability
https://raw.githubusercontent.com/api-evangelist/amazon-kinesis/refs/heads/main/capabilities/data-streams-general.yaml
🔗
NaftikoCapability
https://raw.githubusercontent.com/api-evangelist/amazon-kinesis/refs/heads/main/capabilities/data-streams-account.yaml
🔗
NaftikoCapability
https://raw.githubusercontent.com/api-evangelist/amazon-kinesis/refs/heads/main/capabilities/data-streams-consumers.yaml
🔗
NaftikoCapability
https://raw.githubusercontent.com/api-evangelist/amazon-kinesis/refs/heads/main/capabilities/data-streams-encryption.yaml
🔗
NaftikoCapability
https://raw.githubusercontent.com/api-evangelist/amazon-kinesis/refs/heads/main/capabilities/data-streams-monitoring.yaml
🔗
NaftikoCapability
https://raw.githubusercontent.com/api-evangelist/amazon-kinesis/refs/heads/main/capabilities/data-streams-policies.yaml
🔗
NaftikoCapability
https://raw.githubusercontent.com/api-evangelist/amazon-kinesis/refs/heads/main/capabilities/data-streams-records.yaml
🔗
NaftikoCapability
https://raw.githubusercontent.com/api-evangelist/amazon-kinesis/refs/heads/main/capabilities/data-streams-shards.yaml
🔗
NaftikoCapability
https://raw.githubusercontent.com/api-evangelist/amazon-kinesis/refs/heads/main/capabilities/data-streams-streams.yaml
🔗
NaftikoCapability
https://raw.githubusercontent.com/api-evangelist/amazon-kinesis/refs/heads/main/capabilities/amazon-kinesis-streams.yaml

OpenAPI Specification

amazon-kinesis-data-streams-openapi.yml Raw ↑
openapi: 3.1.0
info:
  title: Amazon Kinesis Data Streams API
  description: >-
    Amazon Kinesis Data Streams is a massively scalable and durable real-time
    data streaming service. It can continuously capture gigabytes of data per
    second from hundreds of thousands of sources such as website clickstreams,
    database event streams, financial transactions, social media feeds, IT logs,
    and location-tracking events. The Kinesis Data Streams API uses a JSON
    protocol over HTTP with the X-Amz-Target header to specify the action.
  version: '2013-12-02'
  contact:
    name: Amazon Web Services
    url: https://aws.amazon.com/kinesis/data-streams/
  license:
    name: Apache 2.0
    url: https://www.apache.org/licenses/LICENSE-2.0
  x-logo:
    url: https://kinlane-productions2.s3.amazonaws.com/apis-json/apis-json-logo.jpg
externalDocs:
  description: Amazon Kinesis Data Streams API Reference
  url: https://docs.aws.amazon.com/kinesis/latest/APIReference/
servers:
  - url: https://kinesis.{region}.amazonaws.com
    description: Amazon Kinesis Data Streams regional endpoint
    variables:
      region:
        default: us-east-1
        description: AWS region
        enum:
          - us-east-1
          - us-east-2
          - us-west-1
          - us-west-2
          - eu-west-1
          - eu-west-2
          - eu-west-3
          - eu-central-1
          - eu-north-1
          - ap-northeast-1
          - ap-northeast-2
          - ap-southeast-1
          - ap-southeast-2
          - ap-south-1
          - sa-east-1
          - ca-central-1
security:
  - aws_sigv4: []
tags:
  - name: Account
    description: Operations for describing and updating account-level settings and limits.
  - name: Consumers
    description: >-
      Operations for registering, describing, listing, and deregistering
      enhanced fan-out consumers.
  - name: Encryption
    description: Operations for starting and stopping server-side encryption on a stream.
  - name: Monitoring
    description: Operations for enabling and disabling enhanced shard-level monitoring.
  - name: Policies
    description: Operations for managing resource-based policies on streams.
  - name: Records
    description: Operations for putting and getting data records to and from a stream.
  - name: Shards
    description: Operations for listing, splitting, merging, and managing shards within a stream.
  - name: Streams
    description: Operations for creating, describing, listing, and managing Kinesis data streams.
paths:
  /#X-Amz-Target=Kinesis_20131202.CreateStream:
    post:
      operationId: CreateStream
      summary: Amazon Kinesis Create a Kinesis data stream
      description: >-
        Creates a Kinesis data stream. A stream captures and transports data
        records that are continuously emitted from different data sources or
        producers. Stream creation is an asynchronous operation. Upon receiving a
        CreateStream request, Kinesis Data Streams immediately returns and sets
        the stream status to CREATING. After the stream is created, Kinesis Data
        Streams sets the stream status to ACTIVE.
      tags:
        - Streams
      parameters:
        - $ref: '#/components/parameters/X-Amz-Target-CreateStream'
      requestBody:
        required: true
        content:
          application/x-amz-json-1.1:
            schema:
              $ref: '#/components/schemas/CreateStreamInput'
      responses:
        '200':
          description: Stream creation initiated successfully.
        '400':
          description: Invalid argument or resource limit exceeded.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/ErrorResponse'
        '409':
          description: Resource already in use.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/ErrorResponse'
  /#X-Amz-Target=Kinesis_20131202.DeleteStream:
    post:
      operationId: DeleteStream
      summary: Amazon Kinesis Delete a Kinesis data stream
      description: >-
        Deletes 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. Stream deletion is an asynchronous operation. After you
        delete a stream, data previously written to the stream is no longer
        accessible.
      tags:
        - Streams
      parameters:
        - $ref: '#/components/parameters/X-Amz-Target-DeleteStream'
      requestBody:
        required: true
        content:
          application/x-amz-json-1.1:
            schema:
              $ref: '#/components/schemas/DeleteStreamInput'
      responses:
        '200':
          description: Stream deletion initiated successfully.
        '400':
          description: Invalid argument or resource limit exceeded.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/ErrorResponse'
        '404':
          description: Resource not found.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/ErrorResponse'
  /#X-Amz-Target=Kinesis_20131202.DescribeStream:
    post:
      operationId: DescribeStream
      summary: Amazon Kinesis Describe a Kinesis data stream
      description: >-
        Describes the specified Kinesis data stream. The information returned
        includes the stream name, Amazon Resource Name (ARN), creation time,
        enhanced metric configuration, and shard map. DescribeStream has a limit
        of 10 transactions per second per account.
      tags:
        - Streams
      parameters:
        - $ref: '#/components/parameters/X-Amz-Target-DescribeStream'
      requestBody:
        required: true
        content:
          application/x-amz-json-1.1:
            schema:
              $ref: '#/components/schemas/DescribeStreamInput'
      responses:
        '200':
          description: Stream description returned successfully.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/DescribeStreamOutput'
        '400':
          description: Invalid argument or limit exceeded.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/ErrorResponse'
        '404':
          description: Resource not found.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/ErrorResponse'
  /#X-Amz-Target=Kinesis_20131202.DescribeStreamSummary:
    post:
      operationId: DescribeStreamSummary
      summary: Amazon Kinesis Get a summary description of a stream
      description: >-
        Provides a summarized description of the specified Kinesis data stream
        without the shard list. The information returned includes the stream
        name, Amazon Resource Name (ARN), status, stream mode, retention period,
        creation time, and encryption details.
      tags:
        - Streams
      parameters:
        - $ref: '#/components/parameters/X-Amz-Target-DescribeStreamSummary'
      requestBody:
        required: true
        content:
          application/x-amz-json-1.1:
            schema:
              $ref: '#/components/schemas/DescribeStreamSummaryInput'
      responses:
        '200':
          description: Stream summary returned successfully.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/DescribeStreamSummaryOutput'
        '400':
          description: Invalid argument or limit exceeded.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/ErrorResponse'
        '404':
          description: Resource not found.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/ErrorResponse'
  /#X-Amz-Target=Kinesis_20131202.ListStreams:
    post:
      operationId: ListStreams
      summary: Amazon Kinesis List Kinesis data streams
      description: >-
        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 Data Streams uses the default
        limit, which is currently 100.
      tags:
        - Streams
      parameters:
        - $ref: '#/components/parameters/X-Amz-Target-ListStreams'
      requestBody:
        required: false
        content:
          application/x-amz-json-1.1:
            schema:
              $ref: '#/components/schemas/ListStreamsInput'
      responses:
        '200':
          description: Stream list returned successfully.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/ListStreamsOutput'
        '400':
          description: Invalid argument or limit exceeded.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/ErrorResponse'
  /#X-Amz-Target=Kinesis_20131202.UpdateStreamMode:
    post:
      operationId: UpdateStreamMode
      summary: Amazon Kinesis Update the capacity mode of a stream
      description: >-
        Updates the capacity mode of the data stream. Currently, in Kinesis Data
        Streams, you can choose between an on-demand capacity mode and a
        provisioned capacity mode for your data streams.
      tags:
        - Streams
      parameters:
        - $ref: '#/components/parameters/X-Amz-Target-UpdateStreamMode'
      requestBody:
        required: true
        content:
          application/x-amz-json-1.1:
            schema:
              $ref: '#/components/schemas/UpdateStreamModeInput'
      responses:
        '200':
          description: Stream mode updated successfully.
        '400':
          description: Invalid argument or resource limit exceeded.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/ErrorResponse'
        '404':
          description: Resource not found.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/ErrorResponse'
  /#X-Amz-Target=Kinesis_20131202.ListShards:
    post:
      operationId: ListShards
      summary: Amazon Kinesis List shards in a stream
      description: >-
        Lists the shards in a stream and provides information about each shard.
        This operation has a limit of 100 transactions per second per data
        stream.
      tags:
        - Shards
      parameters:
        - $ref: '#/components/parameters/X-Amz-Target-ListShards'
      requestBody:
        required: true
        content:
          application/x-amz-json-1.1:
            schema:
              $ref: '#/components/schemas/ListShardsInput'
      responses:
        '200':
          description: Shard list returned successfully.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/ListShardsOutput'
        '400':
          description: Invalid argument or limit exceeded.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/ErrorResponse'
        '404':
          description: Resource not found.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/ErrorResponse'
  /#X-Amz-Target=Kinesis_20131202.SplitShard:
    post:
      operationId: SplitShard
      summary: Amazon Kinesis Split a shard into two shards
      description: >-
        Splits a shard into two new shards in the Kinesis data stream, to
        increase the stream's capacity to ingest and transport data.
        SplitShard is called when there is a need to increase the overall
        capacity of a stream because of an expected increase in the volume
        of data records being ingested.
      tags:
        - Shards
      parameters:
        - $ref: '#/components/parameters/X-Amz-Target-SplitShard'
      requestBody:
        required: true
        content:
          application/x-amz-json-1.1:
            schema:
              $ref: '#/components/schemas/SplitShardInput'
      responses:
        '200':
          description: Shard split initiated successfully.
        '400':
          description: Invalid argument or resource limit exceeded.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/ErrorResponse'
        '404':
          description: Resource not found.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/ErrorResponse'
  /#X-Amz-Target=Kinesis_20131202.MergeShards:
    post:
      operationId: MergeShards
      summary: Amazon Kinesis Merge two adjacent shards
      description: >-
        Merges 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. Two shards are considered adjacent if the union of the
        hash key ranges for the two shards form a contiguous set with no gaps.
      tags:
        - Shards
      parameters:
        - $ref: '#/components/parameters/X-Amz-Target-MergeShards'
      requestBody:
        required: true
        content:
          application/x-amz-json-1.1:
            schema:
              $ref: '#/components/schemas/MergeShardsInput'
      responses:
        '200':
          description: Shard merge initiated successfully.
        '400':
          description: Invalid argument or resource limit exceeded.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/ErrorResponse'
        '404':
          description: Resource not found.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/ErrorResponse'
  /#X-Amz-Target=Kinesis_20131202.UpdateShardCount:
    post:
      operationId: UpdateShardCount
      summary: Amazon Kinesis Update the shard count for a stream
      description: >-
        Updates the shard count of the specified stream to the specified number
        of shards. This API is only supported for the streams with the
        provisioned capacity mode.
      tags:
        - Shards
      parameters:
        - $ref: '#/components/parameters/X-Amz-Target-UpdateShardCount'
      requestBody:
        required: true
        content:
          application/x-amz-json-1.1:
            schema:
              $ref: '#/components/schemas/UpdateShardCountInput'
      responses:
        '200':
          description: Shard count update initiated successfully.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/UpdateShardCountOutput'
        '400':
          description: Invalid argument or resource limit exceeded.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/ErrorResponse'
        '404':
          description: Resource not found.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/ErrorResponse'
  /#X-Amz-Target=Kinesis_20131202.PutRecord:
    post:
      operationId: PutRecord
      summary: Amazon Kinesis Write a single data record to a stream
      description: >-
        Writes a single data record into an Amazon Kinesis data stream. You must
        specify the name or ARN of the stream that captures, stores, and
        transports the data, a partition key, and the data blob itself. The
        partition key is used by Kinesis Data Streams to distribute data across
        shards. Kinesis Data Streams segregates the data records that belong to a
        stream into multiple shards, using the partition key associated with each
        data record to determine the shard to which a given data record belongs.
      tags:
        - Records
      parameters:
        - $ref: '#/components/parameters/X-Amz-Target-PutRecord'
      requestBody:
        required: true
        content:
          application/x-amz-json-1.1:
            schema:
              $ref: '#/components/schemas/PutRecordInput'
      responses:
        '200':
          description: Record written successfully.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/PutRecordOutput'
        '400':
          description: Invalid argument or provisioned throughput exceeded.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/ErrorResponse'
        '404':
          description: Resource not found.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/ErrorResponse'
  /#X-Amz-Target=Kinesis_20131202.PutRecords:
    post:
      operationId: PutRecords
      summary: Amazon Kinesis Write multiple data records to a stream in a single call
      description: >-
        Writes multiple data records into a Kinesis data stream in a single call
        (also referred to as a PutRecords request). Use this operation to send
        data into the stream for data ingestion and processing. Each PutRecords
        request can support up to 500 records. Each record in the request can be
        as large as 1 MiB, up to a limit of 5 MiB for the entire request,
        including partition keys.
      tags:
        - Records
      parameters:
        - $ref: '#/components/parameters/X-Amz-Target-PutRecords'
      requestBody:
        required: true
        content:
          application/x-amz-json-1.1:
            schema:
              $ref: '#/components/schemas/PutRecordsInput'
      responses:
        '200':
          description: Records written (check individual FailedRecordCount).
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/PutRecordsOutput'
        '400':
          description: Invalid argument or provisioned throughput exceeded.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/ErrorResponse'
        '404':
          description: Resource not found.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/ErrorResponse'
  /#X-Amz-Target=Kinesis_20131202.GetShardIterator:
    post:
      operationId: GetShardIterator
      summary: Amazon Kinesis Get an iterator for reading records from a shard
      description: >-
        Gets an Amazon Kinesis shard iterator. A shard iterator expires 5
        minutes after it is returned to the requester. A shard iterator
        specifies the shard position from which to start reading data records
        sequentially. The position is specified using the sequence number of a
        data record in a shard.
      tags:
        - Records
      parameters:
        - $ref: '#/components/parameters/X-Amz-Target-GetShardIterator'
      requestBody:
        required: true
        content:
          application/x-amz-json-1.1:
            schema:
              $ref: '#/components/schemas/GetShardIteratorInput'
      responses:
        '200':
          description: Shard iterator returned successfully.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/GetShardIteratorOutput'
        '400':
          description: Invalid argument or provisioned throughput exceeded.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/ErrorResponse'
        '404':
          description: Resource not found.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/ErrorResponse'
  /#X-Amz-Target=Kinesis_20131202.GetRecords:
    post:
      operationId: GetRecords
      summary: Amazon Kinesis Get data records from a shard
      description: >-
        Gets data records from a Kinesis data stream's shard. Specify a shard
        iterator using the ShardIterator parameter. The shard iterator specifies
        the position in the shard from which you want to start reading data
        records sequentially. Each call to GetRecords can return up to 10 MiB of
        data and up to 10,000 records. Each shard can support up to 5
        transactions per second for reads, up to a maximum total data read rate
        of 2 MiB per second.
      tags:
        - Records
      parameters:
        - $ref: '#/components/parameters/X-Amz-Target-GetRecords'
      requestBody:
        required: true
        content:
          application/x-amz-json-1.1:
            schema:
              $ref: '#/components/schemas/GetRecordsInput'
      responses:
        '200':
          description: Records returned successfully.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/GetRecordsOutput'
        '400':
          description: Invalid argument or provisioned throughput exceeded.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/ErrorResponse'
        '404':
          description: Resource not found.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/ErrorResponse'
  /#X-Amz-Target=Kinesis_20131202.RegisterStreamConsumer:
    post:
      operationId: RegisterStreamConsumer
      summary: Amazon Kinesis Register a stream consumer for enhanced fan-out
      description: >-
        Registers a consumer with a Kinesis data stream. When you use this
        operation, the consumer you register can then call SubscribeToShard to
        receive data from the stream using enhanced fan-out, at a rate of up to
        2 MiB per second for every shard you subscribe to.
      tags:
        - Consumers
      parameters:
        - $ref: '#/components/parameters/X-Amz-Target-RegisterStreamConsumer'
      requestBody:
        required: true
        content:
          application/x-amz-json-1.1:
            schema:
              $ref: '#/components/schemas/RegisterStreamConsumerInput'
      responses:
        '200':
          description: Consumer registered successfully.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/RegisterStreamConsumerOutput'
        '400':
          description: Invalid argument or resource limit exceeded.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/ErrorResponse'
        '404':
          description: Resource not found.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/ErrorResponse'
  /#X-Amz-Target=Kinesis_20131202.DeregisterStreamConsumer:
    post:
      operationId: DeregisterStreamConsumer
      summary: Amazon Kinesis Deregister a stream consumer
      description: >-
        To deregister a consumer, provide its ARN. Alternatively, you can
        provide the ARN of the data stream and the name you gave the consumer
        when you registered it. You may also provide all three parameters, as
        long as they don't conflict with each other.
      tags:
        - Consumers
      parameters:
        - $ref: '#/components/parameters/X-Amz-Target-DeregisterStreamConsumer'
      requestBody:
        required: true
        content:
          application/x-amz-json-1.1:
            schema:
              $ref: '#/components/schemas/DeregisterStreamConsumerInput'
      responses:
        '200':
          description: Consumer deregistered successfully.
        '400':
          description: Invalid argument or resource limit exceeded.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/ErrorResponse'
        '404':
          description: Resource not found.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/ErrorResponse'
  /#X-Amz-Target=Kinesis_20131202.DescribeStreamConsumer:
    post:
      operationId: DescribeStreamConsumer
      summary: Amazon Kinesis Describe a stream consumer
      description: >-
        To get the description of a registered consumer, provide its ARN.
        Alternatively, you can provide the ARN of the data stream and the name
        you gave the consumer when you registered it.
      tags:
        - Consumers
      parameters:
        - $ref: '#/components/parameters/X-Amz-Target-DescribeStreamConsumer'
      requestBody:
        required: true
        content:
          application/x-amz-json-1.1:
            schema:
              $ref: '#/components/schemas/DescribeStreamConsumerInput'
      responses:
        '200':
          description: Consumer description returned successfully.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/DescribeStreamConsumerOutput'
        '400':
          description: Invalid argument or limit exceeded.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/ErrorResponse'
        '404':
          description: Resource not found.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/ErrorResponse'
  /#X-Amz-Target=Kinesis_20131202.ListStreamConsumers:
    post:
      operationId: ListStreamConsumers
      summary: Amazon Kinesis List stream consumers
      description: >-
        Lists the consumers registered to receive data from a stream using
        enhanced fan-out, and provides information about each consumer.
      tags:
        - Consumers
      parameters:
        - $ref: '#/components/parameters/X-Amz-Target-ListStreamConsumers'
      requestBody:
        required: true
        content:
          application/x-amz-json-1.1:
            schema:
              $ref: '#/components/schemas/ListStreamConsumersInput'
      responses:
        '200':
          description: Consumer list returned successfully.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/ListStreamConsumersOutput'
        '400':
          description: Invalid argument or limit exceeded.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/ErrorResponse'
        '404':
          description: Resource not found.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/ErrorResponse'
  /#X-Amz-Target=Kinesis_20131202.SubscribeToShard:
    post:
      operationId: SubscribeToShard
      summary: Amazon Kinesis Subscribe to a shard for enhanced fan-out
      description: >-
        This operation establishes an HTTP/2 connection between the consumer you
        specify in the ConsumerARN parameter and the shard you specify in the
        ShardId parameter. After the connection is successfully established,
        Kinesis Data Streams pushes records from the shard to the consumer over
        this connection. Before you call this operation, call
        RegisterStreamConsumer to register the consumer with the data stream.
        The connection persists for up to 5 minutes.
      tags:
        - Consumers
      parameters:
        - $ref: '#/components/parameters/X-Amz-Target-SubscribeToShard'
      requestBody:
        required: true
        content:
          application/x-amz-json-1.1:
            schema:
              $ref: '#/components/schemas/SubscribeToShardInput'
      responses:
        '200':
          description: Subscription established, event stream opened.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/SubscribeToShardOutput'
        '400':
          description: Invalid argument or resource in use.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/ErrorResponse'
        '404':
          description: Resource not found.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/ErrorResponse'
  /#X-Amz-Target=Kinesis_20131202.EnableEnhancedMonitoring:
    post:
      operationId: EnableEnhancedMonitoring
      summary: Amazon Kinesis Enable enhanced shard-level monitoring
      description: >-
        Enables enhanced Kinesis data stream monitoring for shard-level metrics.
      tags:
        - Monitoring
      parameters:
        - $ref: '#/components/parameters/X-Amz-Target-EnableEnhancedMonitoring'
      requestBody:
        required: true
        content:
          application/x-amz-json-1.1:
            schema:
              $ref: '#/components/schemas/EnableEnhancedMonitoringInput'
      responses:
        '200':
          description: Enhanced monitoring enabled.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/EnhancedMonitoringOutput'
        '400':
          description: Invalid argument or limit exceeded.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/ErrorResponse'
  /#X-Amz-Target=Kinesis_20131202.DisableEnhancedMonitoring:
    post:
      operationId: DisableEnhancedMonitoring
      summary: Amazon Kinesis Disable enhanced shard-level monitoring
      description: >-
        Disables enhanced Kinesis data stream monitoring for shard-level metrics.
      tags:
        - Monitoring
      parameters:
        - $ref: '#/components/parameters/X-Amz-Target-DisableEnhancedMonitoring'
      requestBody:
        required: true
        content:
          application/x-amz-json-1.1:
            schema:
              $ref: '#/components/schemas/DisableEnhancedMonitoringInput'
      responses:
        '200':
          description: Enhanced monitoring disabled.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/EnhancedMonitoringOutput'
        '400':
          description: Invalid argument or limit exceeded.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/ErrorResponse'
  /#X-Amz-Target=Kinesis_20131202.StartStreamEncryption:
    post:
      operationId: StartStreamEncryption
      summary: Amazon Kinesis Enable server-side encryption for a stream
      description: >-
        Enables or updates server-side encryption using an AWS KMS key for a
        specified stream. When invoking this API, you must use either the
        StreamARN or the StreamName parameter, or both.
      tags:
        - Encryption
      parameters:
        - $ref: '#/components/parameters/X-Amz-Target-StartStreamEncryption'
      requestBody:
        required: true
        content:
          application/x-amz-json-1.1:
            schema:
              $ref: '#/components/schemas/StartStreamEncryptionInput'
      responses:
        '200':
          description: Stream encryption initiated.
        '400':
          description: Invalid argument or KMS error.
          content:
            application/x-amz-json-1.1:
              schema:
                $ref: '#/components/schemas/ErrorResponse'
  /#X-Amz-Target=Kinesis_20131202.StopStreamEncryption:
    post:
      operationId: StopStreamEncryption
      summary: Amazon Kinesis Disable server-side encryption for a stream
      description: >-
        Disables server-side encryption for a specified stream. When invoking
        this API, you must 

# --- truncated at 32 KB (82 KB total) ---
# Full source: https://raw.githubusercontent.com/api-evangelist/amazon-kinesis/refs/heads/main/openapi/amazon-kinesis-data-streams-openapi.yml