Search Java Classes and Packages
#Org.apache.kafka.clients.consumer Classes and Interfaces - 16 results found.
| Name | Description | Type | Package | Framework |
| KafkaConsumer | A Kafka client that consumes records from a Kafka cluster. | Class | org.apache.kafka.clients.consumer | Apache Kafka |
| InvalidOffsetException | Thrown when the offset for a set of partitions is invalid (either undefined or out of range), and no reset policy has been configured. | Class | org.apache.kafka.clients.consumer | Apache Kafka |
| ConsumerRecords | A container that holds the list ConsumerRecord per partition for a particular topic. | Class | org.apache.kafka.clients.consumer | Apache Kafka |
| ConsumerRecord | A key/value pair to be received from Kafka. | Class | org.apache.kafka.clients.consumer | Apache Kafka |
| ConsumerRebalanceListener | A callback interface that the user can implement to trigger custom actions when the set of partitions assigned to the This is applicable when the consumer is having Kafka auto-manage group membership. | Interface | org.apache.kafka.clients.consumer | Apache Kafka |
| ConsumerConfig | Class | org.apache.kafka.clients.consumer | Apache Kafka | |
| Consumer | Interface | org.apache.kafka.clients.consumer | Apache Kafka | |
| CommitFailedException | This exception is raised when an offset commit with KafkaConsumer. | Class | org.apache.kafka.clients.consumer | Apache Kafka |
| MockConsumer | A mock of the Consumer interface you can use for testing code that uses Kafka. | Class | org.apache.kafka.clients.consumer | Apache Kafka |
| NoOffsetForPartitionException | Indicates that there is no stored offset for a partition and no defined offsetSee Also:Serialized Form | Class | org.apache.kafka.clients.consumer | Apache Kafka |
| OffsetAndMetadata | The Kafka offset commit API allows users to provide additional metadata (in the form of a string) when an offset is committed. | Class | org.apache.kafka.clients.consumer | Apache Kafka |
| OffsetCommitCallback | A callback interface that the user can implement to trigger custom actions when a commit request completes. | Interface | org.apache.kafka.clients.consumer | Apache Kafka |
| OffsetOutOfRangeException | 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. | Class | org.apache.kafka.clients.consumer | Apache Kafka |
| OffsetResetStrategy | enum OffsetResetStrategyEnum Constant Summary | Class | org.apache.kafka.clients.consumer | Apache Kafka |
| RangeAssignor | The range assignor works on a per-topic basis. | Class | org.apache.kafka.clients.consumer | Apache Kafka |
| RoundRobinAssignor | The roundrobin assignor lays out all the available partitions and all the available consumers. | Class | org.apache.kafka.clients.consumer | Apache Kafka |