A plugin interface that allows you to intercept (and possibly mutate) records received by the consumer.
A callback interface that the user can implement to trigger custom actions when the set of partitions assigned to the consumer changes.
A callback interface that the user can implement to trigger custom actions when a commit request completes.
The consumer configuration keys
A key/value pair to be received from Kafka.
A container that holds the list
A Kafka client that consumes records from a Kafka cluster.
A mock of the
The Kafka offset commit API allows users to provide additional metadata (in the form of a string) when an offset is committed.
The range assignor works on a per-topic basis.
The roundrobin assignor lays out all the available partitions and all the available consumers.
This exception is raised when an offset commit with
Thrown when the offset for a set of partitions is invalid (either undefined or out of range), and no reset policy has been configured.
Indicates that there is no stored offset for a partition and no defined offset reset policy.
No reset policy has been defined, and the offsets for these partitions are either larger or smaller than the range of offsets the server has for the given partition.