|
|||||||||
PREV PACKAGE NEXT PACKAGE | FRAMES NO FRAMES |
Interface Summary | |
---|---|
Consumer | |
ConsumerRebalanceCallback | A callback interface that the user can implement to manage customized offsets on the start and end of every rebalance operation. |
Class Summary | |
---|---|
ConsumerConfig | The consumer configuration keys |
ConsumerRecord | A key/value pair to be received from Kafka. |
ConsumerRecords | A container that holds the list ConsumerRecord per partition for a particular topic. |
KafkaConsumer | A Kafka client that consumes records from a Kafka cluster. |
MockConsumer | A mock of the Consumer interface you can use for testing code that uses Kafka. |
OffsetMetadata | The metadata for an offset commit that has been acknowledged by the server |
|
|||||||||
PREV PACKAGE NEXT PACKAGE | FRAMES NO FRAMES |