アノテーションインターフェース EnableKafkaStreams
@TargetSE(TYPESE)
@RetentionSE(RUNTIMESE)
@DocumentedSE
@Import(KafkaStreamsDefaultConfiguration.class)
public @interface 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 がクラスパス上にあることを確認する必要があります。
- 導入:
- 1.1.4
- 作成者:
- Artem Bilan