クラス KafkaStreamsDefaultConfiguration
java.lang.ObjectSE
org.springframework.kafka.annotation.KafkaStreamsDefaultConfiguration
@Configuration(proxyBeanMethods=false)
public class KafkaStreamsDefaultConfiguration
extends ObjectSE
DEFAULT_STREAMS_CONFIG_BEAN_NAME という名前の StreamsConfig がアプリケーションコンテキストに存在する場合に、StreamsBuilderFactoryBean を登録する @Configuration クラス。それ以外の場合は、UnsatisfiedDependencyException がスローされます。 この構成クラスは、@EnableKafkaStreams アノテーションを使用すると自動的にインポートされます。完全な使用箇所については、EnableKafkaStreams Javadoc を参照してください。
- 導入:
- 1.1.4
- 作成者:
- Artem Bilan, Gary Russell
フィールドサマリー
フィールド修飾子と型フィールド説明static final StringSE自動構成されたデフォルトStreamsBuilderFactoryBeanの Bean 名。static final StringSEデフォルトのStreamsBuilderFactoryBeanBean 定義に使用されるStreamsConfigの Bean 名。コンストラクターのサマリー
コンストラクターメソッドのサマリー
修飾子と型メソッド説明defaultKafkaStreamsBuilder(ObjectProvider<KafkaStreamsConfiguration> streamsConfigProvider, ObjectProvider<StreamsBuilderFactoryBeanConfigurer> configurerProvider) デフォルトのStreamsBuilderFactoryBeanの場合は Bean。
フィールドの詳細
DEFAULT_STREAMS_CONFIG_BEAN_NAME
デフォルトのStreamsBuilderFactoryBeanBean 定義に使用されるStreamsConfigの Bean 名。- 関連事項:
DEFAULT_STREAMS_BUILDER_BEAN_NAME
自動構成されたデフォルトStreamsBuilderFactoryBeanの Bean 名。- 関連事項:
コンストラクターの詳細
KafkaStreamsDefaultConfiguration
public KafkaStreamsDefaultConfiguration()
メソッドの詳細
defaultKafkaStreamsBuilder
@Bean(name="defaultKafkaStreamsBuilder") public StreamsBuilderFactoryBean defaultKafkaStreamsBuilder(@Qualifier("defaultKafkaStreamsConfig") ObjectProvider<KafkaStreamsConfiguration> streamsConfigProvider, ObjectProvider<StreamsBuilderFactoryBeanConfigurer> configurerProvider) デフォルトのStreamsBuilderFactoryBeanの場合は Bean。- パラメーター:
streamsConfigProvider- ストリーム構成。configurerProvider- コンフィギュレーター。- 戻り値:
- ファクトリ Bean。