Interface | Description |
---|---|
RecordPublisher |
A
RecordPublisher will consume records from an external stream and deliver them to the
registered subscriber. |
RecordPublisher.RecordBatchConsumer |
An interface used to collect record batches, and reply with the latest consumed sequence
number.
|
RecordPublisherFactory |
A factory interface used to create instances of
RecordPublisher . |
Class | Description |
---|---|
RecordBatch |
A batch of UserRecords received from Kinesis.
|
Enum | Description |
---|---|
RecordPublisher.RecordPublisherRunResult |
A status enum to represent whether a shard has been fully consumed.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.