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

Class KafkaStreamsFunctionAutoConfiguration

java.lang.Object

org.springframework.cloud.stream.binder.kafka.streams.function.KafkaStreamsFunctionAutoConfiguration

@Configuration
@EnableConfigurationProperties(org.springframework.cloud.stream.function.StreamFunctionProperties.class)
public class KafkaStreamsFunctionAutoConfiguration
extends Object

Since:

2.2.0

Author:

Soby Chacko

Constructor Summary

Constructors

Constructor	Description
KafkaStreamsFunctionAutoConfiguration()

Method Summary

Modifier and Type	Method	Description
KafkaStreamsFunctionBeanPostProcessor	kafkaStreamsFunctionBeanPostProcessor(org.springframework.cloud.stream.function.StreamFunctionProperties streamFunctionProperties)
KafkaStreamsFunctionProcessorInvoker	kafkaStreamsFunctionProcessorInvoker(KafkaStreamsFunctionBeanPostProcessor kafkaStreamsFunctionBeanPostProcessor, KafkaStreamsFunctionProcessor kafkaStreamsFunctionProcessor, KafkaStreamsBindableProxyFactory[] kafkaStreamsBindableProxyFactories, org.springframework.cloud.stream.function.StreamFunctionProperties streamFunctionProperties)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

KafkaStreamsFunctionAutoConfiguration

public KafkaStreamsFunctionAutoConfiguration()

Method Details

kafkaStreamsFunctionProcessorInvoker

@Bean
@Conditional(FunctionDetectorCondition.class)
public KafkaStreamsFunctionProcessorInvoker kafkaStreamsFunctionProcessorInvoker(KafkaStreamsFunctionBeanPostProcessor kafkaStreamsFunctionBeanPostProcessor,
 KafkaStreamsFunctionProcessor kafkaStreamsFunctionProcessor,
 KafkaStreamsBindableProxyFactory[] kafkaStreamsBindableProxyFactories,
 org.springframework.cloud.stream.function.StreamFunctionProperties streamFunctionProperties)

kafkaStreamsFunctionBeanPostProcessor

@Bean
@Conditional(FunctionDetectorCondition.class)
public KafkaStreamsFunctionBeanPostProcessor kafkaStreamsFunctionBeanPostProcessor(org.springframework.cloud.stream.function.StreamFunctionProperties streamFunctionProperties)