Package org.springframework.kafka.support

package org.springframework.kafka.support

Package for kafka support

Related Packages

Package	Description
org.springframework.kafka	Base package for kafka
org.springframework.kafka.support.converter	Package for kafka converters
org.springframework.kafka.support.mapping	Provides classes related to type mapping.
org.springframework.kafka.support.micrometer	Provides classes to support Micrometer.
org.springframework.kafka.support.serializer

Class	Description
AbstractKafkaHeaderMapper	Base for Kafka header mappers.
AbstractKafkaHeaderMapper.HeaderMatcher	A matcher for headers.
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.
Acknowledgment	Handle for acknowledging the processing of a ConsumerRecord.
AllowDenyCollectionManager<T>	Class for managing Allow / Deny collections and its predicates.
CompositeProducerInterceptor<K,V>	A ProducerInterceptor that delegates to a collection of interceptors.
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.
KafkaHeaderMapper	Header mapper for Apache Kafka.
KafkaHeaders	The Kafka specific message headers constants.
KafkaMessageHeaderAccessor	A header accessor to provide convenient access to certain headers in a type specific manner.
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.
LogIfLevelEnabled.Level	Logging levels.
ProducerListener<K,V>	Listener for handling outbound Kafka messages.
SendResult<K,V>	Result for a CompletableFuture 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.
TopicPartitionOffset.SeekPosition	Enumeration for "special" seeks.