org.springframework.kafka.annotation.KafkaStreamsDefaultConfiguration

@Configuration(proxyBeanMethods=false) public class KafkaStreamsDefaultConfiguration extends Object

@Configuration class that registers a StreamsBuilderFactoryBean if StreamsConfig with the name DEFAULT_STREAMS_CONFIG_BEAN_NAME is present in the application context. Otherwise a UnsatisfiedDependencyException is thrown.

This configuration class is automatically imported when using the @EnableKafkaStreams annotation. See EnableKafkaStreams Javadoc for complete usage.

Field Details
- DEFAULT_STREAMS_CONFIG_BEAN_NAME
  
  public static final String DEFAULT_STREAMS_CONFIG_BEAN_NAME
  
  The bean name for the StreamsConfig to be used for the default StreamsBuilderFactoryBean bean definition.
  See Also:
  
  Constant Field Values
- DEFAULT_STREAMS_BUILDER_BEAN_NAME
  
  public static final String DEFAULT_STREAMS_BUILDER_BEAN_NAME
  
  The bean name for auto-configured default StreamsBuilderFactoryBean.
  See Also:
  
  Constant Field Values
Constructor Details
- KafkaStreamsDefaultConfiguration
  
  public KafkaStreamsDefaultConfiguration()
Method Details
- defaultKafkaStreamsBuilder
  
  @Bean(name="defaultKafkaStreamsBuilder") public StreamsBuilderFactoryBean defaultKafkaStreamsBuilder(@Qualifier("defaultKafkaStreamsConfig") ObjectProvider<KafkaStreamsConfiguration> streamsConfigProvider, ObjectProvider<StreamsBuilderFactoryBeanConfigurer> configurerProvider)
  
  Bean for the default StreamsBuilderFactoryBean.
  
  Parameters:
  
  streamsConfigProvider - the streams config.
  
  configurerProvider - the configurer.
  
  Returns:
  
  the factory bean.

Class KafkaStreamsDefaultConfiguration

Field Summary