Package org.springframework.kafka.annotation

Class KafkaStreamsDefaultConfiguration

java.lang.Object

org.springframework.kafka.annotation.KafkaStreamsDefaultConfiguration

@Configuration(proxyBeanMethods=false)
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.

Since:

1.1.4

Author:

Artem Bilan, Gary Russell

Field Summary

Fields

Modifier and Type	Field	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 Summary

Constructors

Constructor	Description
KafkaStreamsDefaultConfiguration()

Method Summary

Modifier and Type	Method	Description
StreamsBuilderFactoryBean	defaultKafkaStreamsBuilder(org.springframework.beans.factory.ObjectProvider<KafkaStreamsConfiguration> streamsConfigProvider, org.springframework.beans.factory.ObjectProvider<StreamsBuilderFactoryBeanCustomizer> customizerProvider)

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_STREAMS_CONFIG_BEAN_NAME

public static final java.lang.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 java.lang.String DEFAULT_STREAMS_BUILDER_BEAN_NAME

The bean name for auto-configured default StreamsBuilderFactoryBean.

See Also:

Constant Field Values

Constructor Detail

KafkaStreamsDefaultConfiguration

public KafkaStreamsDefaultConfiguration()

Method Detail

defaultKafkaStreamsBuilder

@Bean(name="defaultKafkaStreamsBuilder")
public StreamsBuilderFactoryBean defaultKafkaStreamsBuilder(@Qualifier("defaultKafkaStreamsConfig")
                                                            org.springframework.beans.factory.ObjectProvider<KafkaStreamsConfiguration> streamsConfigProvider,
                                                            org.springframework.beans.factory.ObjectProvider<StreamsBuilderFactoryBeanCustomizer> customizerProvider)