Modifier and Type | Method and Description |
---|---|
protected RecordPublisher |
KinesisDataFetcher.createRecordPublisher(SequenceNumber sequenceNumber,
Properties configProps,
MetricGroup metricGroup,
StreamShardHandle subscribedShard) |
protected RecordPublisher |
DynamoDBStreamsDataFetcher.createRecordPublisher(SequenceNumber sequenceNumber,
Properties configProps,
MetricGroup metricGroup,
StreamShardHandle subscribedShard) |
Constructor and Description |
---|
ShardConsumer(KinesisDataFetcher<T> fetcherRef,
RecordPublisher recordPublisher,
Integer subscribedShardStateIndex,
StreamShardHandle subscribedShard,
SequenceNumber lastSequenceNum,
ShardConsumerMetricsReporter shardConsumerMetricsReporter,
KinesisDeserializationSchema<T> shardDeserializer)
Creates a shard consumer.
|
Modifier and Type | Method and Description |
---|---|
RecordPublisher |
RecordPublisherFactory.create(StartingPosition startingPosition,
Properties consumerConfig,
MetricGroup metricGroup,
StreamShardHandle streamShardHandle)
Create a
RecordPublisher . |
Modifier and Type | Class and Description |
---|---|
class |
FanOutRecordPublisher
A
RecordPublisher that will read and forward records from Kinesis using EFO, to the
subscriber. |
Modifier and Type | Class and Description |
---|---|
class |
AdaptivePollingRecordPublisher
An adaptive record publisher to add a dynamic batch read size for
PollingRecordPublisher . |
class |
PollingRecordPublisher
A
RecordPublisher that will read records from Kinesis and forward them to the subscriber. |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.