| Interface | Description |
|---|---|
| AbstractKafkaHeaderMapper.HeaderMatcher |
A matcher for headers.
|
| 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.NeverMatchHeaderMatcher |
A matcher that never matches a set of headers.
|
| 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.
|
| JacksonMimeTypeModule |
A
SimpleModule extension for MimeType serialization. |
| JacksonPresent |
The utility to check if Jackson JSON processor is present in the classpath.
|
| JacksonUtils |
The utilities for Jackson
ObjectMapper instances. |
| JavaUtils |
Chained utility methods to simplify some Java repetitive code.
|
| KafkaHeaders |
The Kafka specific message headers constants.
|
| KafkaNull |
This class represents NULL Kafka payload.
|
| KafkaStreamBrancher<K,V> |
Provides a method-chaining way to build
branches in
Kafka Streams processor topology. |
| 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.
|
| 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[].
|
| TopicPartitionOffset |
A configuration container to represent a topic name, partition number and, optionally,
an offset for it.
|
| TransactionSupport |
Utilities for supporting transactions.
|
| Enum | Description |
|---|---|
| LogIfLevelEnabled.Level |
Logging levels.
|
| TopicPartitionOffset.SeekPosition |
Enumeration for "special" seeks.
|