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 a ConsumerRecord.
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.
AllowDenyCollectionManager<T>	Class for managing Allow / Deny collections and its predicates.
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.
EndpointHandlerMethod	Handler method for retrying endpoints.
ExponentialBackOffWithMaxRetries	Subclass of ExponentialBackOff that allows the specification of the maximum number of retries rather than the maximum elapsed time.
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[].
Suffixer	Utility class that suffixes strings.
TopicForRetryable	Marker to indicate this NewTopic is for retryable topics; admin will ignore these if a regular NewTopic exist.
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.