@Target(value=TYPE) @Retention(value=RUNTIME) @Documented @Import(value=KafkaStreamsDefaultConfiguration.class) public @interface EnableKafkaStreams
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.