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

Packages that use org.springframework.cloud.stream.binder.kafka.streams

Package	Description
org.springframework.cloud.stream.binder.kafka.streams
org.springframework.cloud.stream.binder.kafka.streams.endpoint
org.springframework.cloud.stream.binder.kafka.streams.function
org.springframework.cloud.stream.binder.kafka.streams.properties

Classes in org.springframework.cloud.stream.binder.kafka.streams used by org.springframework.cloud.stream.binder.kafka.streams

Class	Description
AbstractKafkaStreamsBinderProcessor
DeserializationExceptionHandler	Enumeration for various DeserializationExceptionHandler types.
EncodingDecodingBindAdviceHandler	ConfigurationPropertiesBindHandlerAdvisor to detect nativeEncoding/Decoding settings provided by the application explicitly.
GlobalKTableBinder	An AbstractBinder implementation for GlobalKTable.
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.
KafkaStreamsBindingInformationCatalogue	A catalogue that provides binding information for Kafka Streams target types such as KStream.
KafkaStreamsFunctionProcessor
KafkaStreamsMessageConversionDelegate	Delegate for handling all framework level message conversions inbound and outbound on KStream.
KafkaStreamsRegistry	An internal registry for holding KafkaStreams objects maintained through StreamsBuilderFactoryManager.
KeyValueSerdeResolver	Resolver for key and value Serde.
SendToDlqAndContinue	Custom implementation for ConsumerRecordRecoverer that keeps a collection of recoverer objects per input topics.
StreamsBuilderFactoryManager	Iterate through all StreamsBuilderFactoryBean in the application context and start them.

Classes in org.springframework.cloud.stream.binder.kafka.streams used by org.springframework.cloud.stream.binder.kafka.streams.endpoint

Class	Description
KafkaStreamsRegistry	An internal registry for holding KafkaStreams objects maintained through StreamsBuilderFactoryManager.

Classes in org.springframework.cloud.stream.binder.kafka.streams used by org.springframework.cloud.stream.binder.kafka.streams.function

Class	Description
KafkaStreamsFunctionProcessor

Classes in org.springframework.cloud.stream.binder.kafka.streams used by org.springframework.cloud.stream.binder.kafka.streams.properties

Class	Description
DeserializationExceptionHandler	Enumeration for various DeserializationExceptionHandler types.