kinesis/aws.sdk.kotlin.services.kinesis.model/SubscribeToShardEvent

SubscribeToShardEvent

After you call SubscribeToShard, Kinesis Data Streams sends events of this type over an HTTP/2 connection to your consumer.

Types

Builder

class Builder

Companion

object Companion

Properties

childShards

val childShards: List<ChildShard>?

The list of the child shards of the current shard, returned only at the end of the current shard.

continuationSequenceNumber

val continuationSequenceNumber: String

Use this as SequenceNumber in the next call to SubscribeToShard, with StartingPosition set to AT_SEQUENCE_NUMBER or AFTER_SEQUENCE_NUMBER. Use ContinuationSequenceNumber for checkpointing because it captures your shard progress even when no data is written to the shard.

millisBehindLatest

val millisBehindLatest: Long

The number of milliseconds the read records are from the tip of the stream, indicating how far behind current time the consumer is. A value of zero indicates that record processing is caught up, and there are no new records to process at this moment.

records

val records: List<Record>

Functions

copy

inline fun copy(block: SubscribeToShardEvent.Builder.() -> Unit = {}): SubscribeToShardEvent

equals

open operator override fun equals(other: Any?): Boolean

hashCode

open override fun hashCode(): Int

toString

open override fun toString(): String