アノテーションインターフェース EnableKafkaStreams

デフォルトの Kafka Streams コンポーネントを有効にします。次のように Configuration クラスで使用します。

 @Configuration
 @EnableKafkaStreams
 public class AppConfig {

        @Bean(name = KafkaStreamsDefaultConfiguration.DEFAULT_STREAMS_CONFIG_BEAN_NAME)
  public KafkaStreamsConfiguration kStreamsConfigs() {
     ...
  }
        // other @Bean definitions
 }
 

その KafkaStreamsDefaultConfiguration.DEFAULT_STREAMS_CONFIG_BEAN_NAME は、KafkaStreamsDefaultConfiguration.DEFAULT_STREAMS_BUILDER_BEAN_NAME で StreamsBuilderFactoryBean を宣言するために必要です。

また、Kafka ストリーム機能を有効にするには、kafka-streams jar がクラスパス上にあることを確認する必要があります。