Package org.springframework.cloud.stream.binder.kafka.streams

Interface Summary

Interface	Description
GlobalKTableBoundElementFactory.GlobalKTableWrapper	Wrapper for GlobalKTable proxy.

Class Summary

Class	Description
AbstractKafkaStreamsBinderProcessor
EncodingDecodingBindAdviceHandler	ConfigurationPropertiesBindHandlerAdvisor to detect nativeEncoding/Decoding settings provided by the application explicitly.
GlobalKTableBinder	An AbstractBinder implementation for GlobalKTable.
GlobalKTableBinderConfiguration	Configuration for GlobalKTable binder.
GlobalKTableBoundElementFactory	BindingTargetFactory for GlobalKTable Input bindings are only created as output bindings on GlobalKTable are not allowed.
InteractiveQueryService	Services pertinent to the interactive query capabilities of Kafka Streams.
KafkaStreamsBinderHealthIndicator	Health indicator for Kafka Streams.
KafkaStreamsBinderMetrics	Kafka Streams binder metrics implementation that exports the metrics available through KafkaStreams.metrics() into a micrometer MeterRegistry.
KafkaStreamsBinderSupportAutoConfiguration	Kafka Streams binder configuration.
KafkaStreamsFunctionProcessor
KafkaStreamsMessageConversionDelegate	Delegate for handling all framework level message conversions inbound and outbound on KStream.
KeyValueSerdeResolver	Resolver for key and value Serde.
KStreamBinderConfiguration	Configuration for KStream binder.
KTableBinderConfiguration	Configuration for KTable binder.
MultiBinderPropertiesConfiguration
SendToDlqAndContinue	Custom implementation for ConsumerRecordRecoverer that keeps a collection of recoverer objects per input topics.

Enum Summary

Enum	Description
DeserializationExceptionHandler	Enumeration for various DeserializationExceptionHandler types.