Class and Description |
---|
RecordPublisher
A
RecordPublisher will consume records from an external stream and deliver them to the
registered subscriber. |
RecordPublisherFactory
A factory interface used to create instances of
RecordPublisher . |
Class and Description |
---|
RecordBatch
A batch of UserRecords received from Kinesis.
|
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.
|
RecordPublisher.RecordPublisherRunResult
A status enum to represent whether a shard has been fully consumed.
|
Class and 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.
|
RecordPublisher.RecordPublisherRunResult
A status enum to represent whether a shard has been fully consumed.
|
RecordPublisherFactory
A factory interface used to create instances of
RecordPublisher . |
Class and 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.
|
RecordPublisher.RecordPublisherRunResult
A status enum to represent whether a shard has been fully consumed.
|
RecordPublisherFactory
A factory interface used to create instances of
RecordPublisher . |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.