Class KafkaStreamsDefaultConfiguration
java.lang.Object
org.springframework.kafka.annotation.KafkaStreamsDefaultConfiguration
@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.
- Since:
- 1.1.4
- Author:
- Artem Bilan, Gary Russell
-
Field Summary
Modifier and TypeFieldDescriptionstatic final String
The bean name for auto-configured defaultStreamsBuilderFactoryBean
.static final String
The bean name for theStreamsConfig
to be used for the defaultStreamsBuilderFactoryBean
bean definition. -
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptiondefaultKafkaStreamsBuilder
(ObjectProvider<KafkaStreamsConfiguration> streamsConfigProvider, ObjectProvider<StreamsBuilderFactoryBeanConfigurer> configurerProvider) Bean for the defaultStreamsBuilderFactoryBean
.
-
Field Details
-
DEFAULT_STREAMS_CONFIG_BEAN_NAME
The bean name for theStreamsConfig
to be used for the defaultStreamsBuilderFactoryBean
bean definition.- See Also:
-
DEFAULT_STREAMS_BUILDER_BEAN_NAME
The bean name for auto-configured defaultStreamsBuilderFactoryBean
.- See Also:
-
-
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 defaultStreamsBuilderFactoryBean
.- Parameters:
streamsConfigProvider
- the streams config.configurerProvider
- the configurer.- Returns:
- the factory bean.
-