Uses of Class
org.springframework.cloud.stream.binder.kafka.streams.KafkaStreamsFunctionProcessor
Packages that use KafkaStreamsFunctionProcessor
Package
Description
-
Uses of KafkaStreamsFunctionProcessor in org.springframework.cloud.stream.binder.kafka.streams
Methods in org.springframework.cloud.stream.binder.kafka.streams that return KafkaStreamsFunctionProcessorModifier and TypeMethodDescriptionKafkaStreamsBinderSupportAutoConfiguration.kafkaStreamsFunctionProcessor(org.springframework.cloud.stream.config.BindingServiceProperties bindingServiceProperties, KafkaStreamsExtendedBindingProperties kafkaStreamsExtendedBindingProperties, KeyValueSerdeResolver keyValueSerdeResolver, KafkaStreamsBindingInformationCatalogue kafkaStreamsBindingInformationCatalogue, KafkaStreamsMessageConversionDelegate kafkaStreamsMessageConversionDelegate, org.springframework.beans.factory.ObjectProvider<org.springframework.kafka.core.CleanupConfig> cleanupConfig, org.springframework.cloud.stream.function.StreamFunctionProperties streamFunctionProperties, KafkaStreamsBinderConfigurationProperties kafkaStreamsBinderConfigurationProperties, org.springframework.beans.factory.ObjectProvider<org.springframework.kafka.config.StreamsBuilderFactoryBeanConfigurer> customizerProvider, org.springframework.core.env.ConfigurableEnvironment environment) -
Uses of KafkaStreamsFunctionProcessor in org.springframework.cloud.stream.binder.kafka.streams.function
Methods in org.springframework.cloud.stream.binder.kafka.streams.function with parameters of type KafkaStreamsFunctionProcessorModifier and TypeMethodDescriptionKafkaStreamsFunctionAutoConfiguration.kafkaStreamsFunctionProcessorInvoker(KafkaStreamsFunctionBeanPostProcessor kafkaStreamsFunctionBeanPostProcessor, KafkaStreamsFunctionProcessor kafkaStreamsFunctionProcessor, KafkaStreamsBindableProxyFactory[] kafkaStreamsBindableProxyFactories, org.springframework.cloud.stream.function.StreamFunctionProperties streamFunctionProperties) Constructors in org.springframework.cloud.stream.binder.kafka.streams.function with parameters of type KafkaStreamsFunctionProcessorModifierConstructorDescriptionKafkaStreamsFunctionProcessorInvoker(Map<String, org.springframework.core.ResolvableType> resolvableTypeMap, KafkaStreamsFunctionProcessor kafkaStreamsFunctionProcessor, KafkaStreamsBindableProxyFactory[] kafkaStreamsBindableProxyFactories, Map<String, Method> methods, org.springframework.cloud.stream.function.StreamFunctionProperties streamFunctionProperties)