| 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 |
|---|---|
| AbstractKafkaHeaderMapper |
Base for Kafka header mappers.
|
| AbstractKafkaHeaderMapper.SimplePatternBasedHeaderMatcher |
A pattern-based header matcher that matches if the specified
header matches the specified simple pattern.
|
| CompositeProducerListener<K,V> |
A
ProducerListener that delegates to a collection of listeners. |
| DefaultKafkaHeaderMapper |
Default header mapper for Apache Kafka.
|
| DefaultKafkaHeaderMapper.NonTrustedHeaderType |
Represents a header that could not be decoded due to an untrusted type.
|
| 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.
|
| KafkaUtils |
Utility methods.
|
| LoggingProducerListener<K,V> |
The
ProducerListener that logs exceptions thrown when sending messages. |
| LogIfLevelEnabled |
Wrapper for a commons-logging Log supporting configurable
logging levels.
|
| ProducerListenerAdapter<K,V> | Deprecated
as the
ProducerListener has default methods and can be implemented directly without the need for this adapter |
| SeekUtils |
Seek utilities.
|
| SendResult<K,V> |
Result for a Listenablefuture after a send.
|
| SimpleKafkaHeaderMapper |
A simple header mapper that maps headers directly; for outbound,
only byte[] headers are mapped; for inbound, headers are mapped
unchanged, as byte[].
|
| TopicPartitionInitialOffset |
A configuration container to represent a topic name, partition number and, optionally,
an initial offset for it.
|
| TransactionSupport |
Utilities for supporting transactions.
|
| Enum | Description |
|---|---|
| LogIfLevelEnabled.Level |
Logging levels.
|
| TopicPartitionInitialOffset.SeekPosition |
Enumeration for "special" seeks.
|