|
|
|
@ -4,6 +4,7 @@ import org.apache.kafka.streams.StreamsBuilder;
|
|
|
|
|
import org.apache.kafka.streams.kstream.KStream;
|
|
|
|
|
import org.springframework.context.annotation.Bean;
|
|
|
|
|
import org.springframework.context.annotation.Configuration;
|
|
|
|
|
import org.springframework.kafka.annotation.EnableKafkaStreams;
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* kafka stream 配置
|
|
|
|
@ -11,6 +12,7 @@ import org.springframework.context.annotation.Configuration;
|
|
|
|
|
* @author LionLi
|
|
|
|
|
*/
|
|
|
|
|
@Configuration
|
|
|
|
|
@EnableKafkaStreams
|
|
|
|
|
public class KafkaStreamsConfig {
|
|
|
|
|
|
|
|
|
|
@Bean
|
|
|
|
|