@Internal public interface RecordPublisher
RecordPublisher
will consume records from an external stream and deliver them to the
registered subscriber.Modifier and Type | Interface and Description |
---|---|
static interface |
RecordPublisher.RecordBatchConsumer
An interface used to collect record batches, and reply with the latest consumed sequence
number.
|
static class |
RecordPublisher.RecordPublisherRunResult
A status enum to represent whether a shard has been fully consumed.
|
Modifier and Type | Method and Description |
---|---|
RecordPublisher.RecordPublisherRunResult |
run(RecordPublisher.RecordBatchConsumer recordBatchConsumer)
Run the record publisher.
|
RecordPublisher.RecordPublisherRunResult run(RecordPublisher.RecordBatchConsumer recordBatchConsumer) throws InterruptedException
recordBatchConsumer
- the record batch consumer in which to output recordsInterruptedException
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.