Package org.springframework.kafka.support
package org.springframework.kafka.support
Package for kafka support
-
ClassDescriptionBase for Kafka header mappers.A matcher for headers.A matcher that never matches a set of headers.A pattern-based header matcher that matches if the specified header matches the specified simple pattern.Handle for acknowledging the processing of a
ConsumerRecord
.Class for managing Allow / Deny collections and its predicates.AProducerInterceptor
that delegates to a collection of interceptors.AProducerListener
that delegates to a collection of listeners.Default header mapper for Apache Kafka.Represents a header that could not be decoded due to an untrusted type.Handler method for retrying endpoints.Subclass ofExponentialBackOff
that allows the specification of the maximum number of retries rather than the maximum elapsed time.ASimpleModule
extension forMimeType
serialization.The utility to check if Jackson JSON processor is present in the classpath.The utilities for JacksonObjectMapper
instances.Chained utility methods to simplify some Java repetitive code.Header mapper for Apache Kafka.The Kafka specific message headers constants.A header accessor to provide convenient access to certain headers in a type specific manner.This class represents NULL Kafka payload.KafkaStreamBrancher<K,V> Provides a method-chaining way to buildbranches
in Kafka Streams processor topology.Utility methods.TheProducerListener
that logs exceptions thrown when sending messages.Wrapper for a commons-logging Log supporting configurable logging levels.Logging levels.ProducerListener<K,V> Listener for handling outbound Kafka messages.SendResult<K,V> Result for aCompletableFuture
after a send.A simple header mapper that maps headers directly; for outbound, only byte[] headers are mapped; for inbound, headers are mapped unchanged, as byte[].Utility class that suffixes strings.Marker to indicate thisNewTopic
is for retryable topics; admin will ignore these if a regularNewTopic
exist.A configuration container to represent a topic name, partition number and, optionally, an offset for it.Enumeration for "special" seeks.