@Internal public class ShardConsumer<T> extends Object implements Runnable
RecordPublisher
. Each thread is in charge of one
Kinesis shard only.
A ShardConsumer
is responsible for:
RecordPublisher
to consume all records from the subscribed shard
KinesisDataFetcher
Constructor and Description |
---|
ShardConsumer(KinesisDataFetcher<T> fetcherRef,
RecordPublisher recordPublisher,
Integer subscribedShardStateIndex,
StreamShardHandle subscribedShard,
SequenceNumber lastSequenceNum,
ShardConsumerMetricsReporter shardConsumerMetricsReporter,
KinesisDeserializationSchema<T> shardDeserializer)
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 fetcherrecordPublisher
- the record publisher used to read records from kinesissubscribedShardStateIndex
- the state index of the shard this consumer is subscribed tosubscribedShard
- the shard this consumer is subscribed tolastSequenceNum
- the sequence number in the shard to start consumingshardConsumerMetricsReporter
- the reporter to report metrics toshardDeserializer
- used to deserialize incoming recordsCopyright © 2014–2023 The Apache Software Foundation. All rights reserved.