Defines whether to accept
Used to persist the state of the partition consumer.
Defines how some state will be persisted/managed.
Abstract implementation of PartitionConsumer, which manages state persistence and serialization/deserialization before delegating to the abstract methods.
Responsible for serialization and deserialization of
Configuration parameters to be used by a
A Builder to construct ConsumerConfiguration instances.
Keeps track of a list of partitions that are either available for consuming or are currently being consumed.
Default implementation of
An implementation of PartitionAcceptor which limits the number of accepted partitions to a given value.
A utility class for batch processing (i.e.
Returns access to a list of partitions for consuming, as well as a list of
Codec used to serialize and deserialize
Return value, determining what to do with a Partition.
Represents the process/consumed state of the partition.
Copyright © 2018 Cask Data, Inc.. All rights reserved.