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 register_stream_consumer
to register the consumer with Kinesis Data Streams.
See https://www.paws-r-sdk.com/docs/kinesis_subscribe_to_shard/ for full documentation.
kinesis_subscribe_to_shard(ConsumerARN, ShardId, StartingPosition)
[required] For this parameter, use the value you obtained when you called
register_stream_consumer
.
[required] The ID of the shard you want to subscribe to. To see a list of all the
shards for a given stream, use list_shards
.
[required] The starting position in the data stream from which to start streaming.