An interface used to collect record batches, and reply with the latest consumed sequence number.
A factory interface used to create instances of
A batch of UserRecords received from Kinesis.
A status enum to represent whether a shard has been fully consumed.
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.