| Interface | Description |
|---|---|
| Acknowledgment |
Handle for acknowledging the processing of a
ConsumerRecord. |
| ProducerListener<K,V> |
Listener for handling outbound Kafka messages.
|
| Class | Description |
|---|---|
| KafkaHeaders |
The Kafka specific message headers constants.
|
| KafkaNull |
This class represents NULL Kafka payload.
|
| LoggingProducerListener<K,V> |
The
ProducerListener that logs exceptions thrown when sending messages. |
| ProducerListenerAdapter<K,V> |
No-op implementation of
ProducerListener, to be used as base class for other implementations. |
| SendResult<K,V> |
Result for a Listenablefuture after a send.
|
| TopicPartitionInitialOffset |
A configuration container to represent a topic name, partition number and, optionally,
an initial offset for it.
|