|Modifier and Type
|Interface and Description
An interface used to collect record batches, and reply with the latest consumed sequence number.
A status enum to represent whether a shard has been fully consumed.
RecordPublisher.RecordPublisherRunResult run(RecordPublisher.RecordBatchConsumer recordBatchConsumer) throws InterruptedException
recordBatchConsumer - the record batch consumer in which to output records
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.