All Classes and Interfaces
Class
Description
A Kafka consumer that manually commits offsets and supports asynchronous message processing
Processes a Kafka message and tracks the message offsets that have been successfully processed and can be committed
Keeps track of message offsets that are (a) being processed and (b) have been processed and can be committed
Tracks the offsets for a TopicPartition that are being processed or have been processed