| Interface | Description |
|---|---|
| Acknowledgment |
Handle for acknowledging the processing of a
ConsumerRecord. |
| KafkaHeaderMapper |
Header mapper for Apache Kafka.
|
| ProducerListener<K,V> |
Listener for handling outbound Kafka messages.
|
| Class | Description |
|---|---|
| DefaultKafkaHeaderMapper |
Default header mapper for Apache Kafka.
|
| DefaultKafkaHeaderMapper.NonTrustedHeaderType |
Represents a header that could not be decoded due to an untrusted type.
|
| DefaultKafkaHeaderMapper.SimplePatternBasedHeaderMatcher |
A pattern-based header matcher that matches if the specified
header matches the specified simple pattern.
|
| JacksonPresent |
The utility to check if Jackson JSON processor is present in the classpath.
|
| 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. |
| LogIfLevelEnabled |
Wrapper for a commons-logging Log supporting configurable
logging levels.
|
| MimeTypeJsonDeserializer |
MimeType deserializer. |
| 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.
|
| Enum | Description |
|---|---|
| LogIfLevelEnabled.Level |
Logging levels.
|
| TopicPartitionInitialOffset.SeekPosition |
Enumeration for "special" seeks.
|