Uses of Package
org.springframework.kafka.support
Package
Description
Package for kafka annotations
Package for kafka configuration
Package for kafka core components
Package for kafka listeners
Provides classes for adapting listeners.
Provides classes for request/reply semantics.
Package for retryable topic handling.
Package for kafka support
Package for kafka converters
-
ClassDescriptionA configuration container to represent a topic name, partition number and, optionally, an offset for it.
-
ClassDescriptionA configuration container to represent a topic name, partition number and, optionally, an offset for it.
-
ClassDescriptionListener for handling outbound Kafka messages.Result for a
CompletableFuture
after a send.A configuration container to represent a topic name, partition number and, optionally, an offset for it. -
ClassDescriptionHandle for acknowledging the processing of a
ConsumerRecord
.Logging levels.Result for aCompletableFuture
after a send.A configuration container to represent a topic name, partition number and, optionally, an offset for it. -
ClassDescriptionHandle for acknowledging the processing of a
ConsumerRecord
.Header mapper for Apache Kafka.This class represents NULL Kafka payload. -
-
-
ClassDescriptionBase for Kafka header mappers.A matcher for headers.Class for managing Allow / Deny collections and its predicates.Default header mapper for Apache Kafka.Handler method for retrying endpoints.Chained utility methods to simplify some Java repetitive code.Header mapper for Apache Kafka.A header accessor to provide convenient access to certain headers in a type specific manner.This class represents NULL Kafka payload.Provides a method-chaining way to build
branches
in Kafka Streams processor topology.Logging levels.Listener for handling outbound Kafka messages.A simple header mapper that maps headers directly; for outbound, only byte[] headers are mapped; for inbound, headers are mapped unchanged, as byte[].Enumeration for "special" seeks. -
ClassDescriptionHandle for acknowledging the processing of a
ConsumerRecord
.Header mapper for Apache Kafka.