@Internal public class ShardConsumer<T> extends Object implements Runnable
RecordPublisher. Each thread is in charge of one Kinesis shard only.
ShardConsumer is responsible for:
RecordPublisherto consume all records from the subscribed shard
|Constructor and Description|
Creates a shard consumer.
public ShardConsumer(KinesisDataFetcher<T> fetcherRef, RecordPublisher recordPublisher, Integer subscribedShardStateIndex, StreamShardHandle subscribedShard, SequenceNumber lastSequenceNum, ShardConsumerMetricsReporter shardConsumerMetricsReporter, KinesisDeserializationSchema<T> shardDeserializer)
fetcherRef- reference to the owning fetcher
recordPublisher- the record publisher used to read records from kinesis
subscribedShardStateIndex- the state index of the shard this consumer is subscribed to
subscribedShard- the shard this consumer is subscribed to
lastSequenceNum- the sequence number in the shard to start consuming
shardConsumerMetricsReporter- the reporter to report metrics to
shardDeserializer- used to deserialize incoming records
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.