Package org.springframework.kafka.streams

@NullMarked package org.springframework.kafka.streams

Package for classes related to Kafka Streams.

Related Packages

Package	Description
org.springframework.kafka	Base package for kafka
org.springframework.kafka.streams.messaging	Package for classes related to spring-messaging with Kafka Streams.

Class	Description
AbstractRecoveringExceptionHandler<R>	Abstract base class for recovering Kafka Streams exception handlers.
HeaderEnricherProcessor<K,V>	Manipulate the headers.
HeaderEnricherProcessor.Container<K,V>	Container object for SpEL evaluation.
KafkaStreamsDeadLetterDestinationResolver	Interface for resolving the dead-letter topic destination of a failed record handled by either RecoveringDeserializationExceptionHandler, RecoveringProcessingExceptionHandler, or RecoveringProductionExceptionHandler through the native Kafka Streams DLQ.
KafkaStreamsInteractiveQueryService	Provide a wrapper API around the interactive query stores in Kafka Streams.
KafkaStreamsMicrometerListener	Creates a KafkaStreamsMetrics for the KafkaStreams.
RecoveringDeserializationExceptionHandler	A DeserializationExceptionHandler that calls a ConsumerRecordRecoverer or uses the native Kafka Streams DLQ and continues.
RecoveringProcessingExceptionHandler	A ProcessingExceptionHandler that calls a ConsumerRecordRecoverer or uses the native Kafka Streams DLQ and continues.
RecoveringProductionExceptionHandler	A ProductionExceptionHandler that calls a ConsumerRecordRecoverer or uses the native Kafka Streams DLQ and continues.