Package org.springframework.kafka.support
Package for kafka support
-
Interface Summary Interface Description AbstractKafkaHeaderMapper.HeaderMatcher A matcher for headers.Acknowledgment Handle for acknowledging the processing of aConsumerRecord
.KafkaHeaderMapper Header mapper for Apache Kafka.ProducerListener<K,V> Listener for handling outbound Kafka messages. -
Class Summary 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> AProducerListener
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 ASimpleModule
extension forMimeType
serialization.JacksonPresent The utility to check if Jackson JSON processor is present in the classpath.JacksonUtils The utilities for JacksonObjectMapper
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 buildbranches
in Kafka Streams processor topology.KafkaUtils Utility methods.LoggingProducerListener<K,V> TheProducerListener
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 Summary Enum Description LogIfLevelEnabled.Level Logging levels.TopicPartitionOffset.SeekPosition Enumeration for "special" seeks.