org.springframework.kafka.annotation

Annotation Type EnableKafkaStreams

@Target(value=TYPE)
 @Retention(value=RUNTIME)
 @Documented
 @Import(value=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 = KStreamDefaultConfiguration.DEFAULT_STREAMS_CONFIG_BEAN_NAME)
  public StreamsConfig 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