Interface | Description |
---|---|
Consumer<K,V> | |
ConsumerRebalanceCallback |
A callback interface that the user can implement to trigger custom actions when the set of partitions assigned to the
consumer changes.
|
Class | Description |
---|---|
ConsumerConfig |
The consumer configuration keys
|
ConsumerRecord<K,V> |
A key/value pair to be received from Kafka.
|
ConsumerRecords<K,V> |
A container that holds the list
ConsumerRecord per partition for a
particular topic. |
KafkaConsumer<K,V> |
A Kafka client that consumes records from a Kafka cluster.
|
MockConsumer<K,V> |
A mock of the
Consumer interface you can use for testing code that uses Kafka. |
Enum | Description |
---|---|
CommitType |
Exception | Description |
---|---|
NoOffsetForPartitionException |
Indicates that there is no stored offset and no defined offset reset policy
|