Class | Description |
---|---|
FanOutRecordPublisher |
A
RecordPublisher that will read and forward records from Kinesis using EFO, to the
subscriber. |
FanOutRecordPublisherConfiguration |
This is a configuration class for enhanced fan-out components.
|
FanOutRecordPublisherFactory |
A
RecordPublisher factory used to create instances of FanOutRecordPublisher . |
FanOutShardSubscriber |
This class is responsible for acquiring an Enhanced Fan Out subscription and consuming records
from a shard.
|
StreamConsumerRegistrar |
Responsible for registering and deregistering EFO stream consumers.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.