@Configuration
public class KafkaStreamsDefaultConfiguration
extends java.lang.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.
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
DEFAULT_STREAMS_BUILDER_BEAN_NAME
The bean name for auto-configured default
StreamsBuilderFactoryBean . |
static java.lang.String |
DEFAULT_STREAMS_CONFIG_BEAN_NAME
The bean name for the
StreamsConfig to be used for the default
StreamsBuilderFactoryBean bean definition. |
Constructor and Description |
---|
KafkaStreamsDefaultConfiguration() |
Modifier and Type | Method and Description |
---|---|
StreamsBuilderFactoryBean |
defaultKafkaStreamsBuilder(org.springframework.beans.factory.ObjectProvider<org.apache.kafka.streams.StreamsConfig> streamsConfigProvider) |
public static final java.lang.String DEFAULT_STREAMS_CONFIG_BEAN_NAME
StreamsConfig
to be used for the default
StreamsBuilderFactoryBean
bean definition.public static final java.lang.String DEFAULT_STREAMS_BUILDER_BEAN_NAME
StreamsBuilderFactoryBean
.@Bean(name="defaultKafkaStreamsBuilder") public StreamsBuilderFactoryBean defaultKafkaStreamsBuilder(@Qualifier(value="defaultKafkaStreamsConfig") org.springframework.beans.factory.ObjectProvider<org.apache.kafka.streams.StreamsConfig> streamsConfigProvider)