Annotation Interface EnableKafkaStreams

@Target(TYPE)
@Retention(RUNTIME)
@Documented
@Import(KafkaStreamsDefaultConfiguration.class)
public @interface EnableKafkaStreams

Enable default Kafka Streams components. To be used on Configuration classes as follows:

 @Configuration
 @EnableKafkaStreams
 public class AppConfig {

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

That KafkaStreamsDefaultConfiguration.DEFAULT_STREAMS_CONFIG_BEAN_NAME is required to declare StreamsBuilderFactoryBean with the KafkaStreamsDefaultConfiguration.DEFAULT_STREAMS_BUILDER_BEAN_NAME.

Also to enable Kafka Streams feature you should be sure that the kafka-streams jar is on classpath.

Since:

1.1.4

Author:

Artem Bilan