org.springframework.kafka.annotation

Class KafkaStreamsDefaultConfiguration

java.lang.Object

org.springframework.kafka.annotation.KafkaStreamsDefaultConfiguration

@Configuration
public class KafkaStreamsDefaultConfiguration
extends java.lang.Object

@Configuration class that registers a KStreamBuilderFactoryBean 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

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	DEFAULT_KSTREAM_BUILDER_BEAN_NAME The bean name for auto-configured default KStreamBuilderFactoryBean.
static java.lang.String	DEFAULT_STREAMS_CONFIG_BEAN_NAME The bean name for the StreamsConfig to be used for the default KStreamBuilderFactoryBean bean definition.

Constructor Summary

Constructors

Constructor and Description
KafkaStreamsDefaultConfiguration()

Method Summary

Modifier and Type	Method and Description
KStreamBuilderFactoryBean	defaultKStreamBuilder(org.springframework.beans.factory.ObjectProvider<org.apache.kafka.streams.StreamsConfig> streamsConfigProvider)

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 KStreamBuilderFactoryBean bean definition.

See Also:

Constant Field Values

DEFAULT_KSTREAM_BUILDER_BEAN_NAME

public static final java.lang.String DEFAULT_KSTREAM_BUILDER_BEAN_NAME

The bean name for auto-configured default KStreamBuilderFactoryBean.

See Also:

Constant Field Values

Constructor Detail

KafkaStreamsDefaultConfiguration

public KafkaStreamsDefaultConfiguration()

Method Detail

defaultKStreamBuilder

@Bean(name="defaultKStreamBuilder")
public KStreamBuilderFactoryBean defaultKStreamBuilder(@Qualifier(value="defaultKafkaStreamsConfig")
                                                                                           org.springframework.beans.factory.ObjectProvider<org.apache.kafka.streams.StreamsConfig> streamsConfigProvider)