|
|
|
@ -31,9 +31,9 @@ import org.springframework.context.annotation.Bean;
|
|
|
|
|
import org.springframework.context.annotation.Configuration;
|
|
|
|
|
import org.springframework.kafka.annotation.EnableKafkaStreams;
|
|
|
|
|
import org.springframework.kafka.annotation.KafkaListener;
|
|
|
|
|
import org.springframework.kafka.config.StreamsBuilderFactoryBean;
|
|
|
|
|
import org.springframework.kafka.core.DefaultKafkaProducerFactory;
|
|
|
|
|
import org.springframework.kafka.core.KafkaTemplate;
|
|
|
|
|
import org.springframework.kafka.core.StreamsBuilderFactoryBean;
|
|
|
|
|
import org.springframework.kafka.support.KafkaHeaders;
|
|
|
|
|
import org.springframework.kafka.test.rule.EmbeddedKafkaRule;
|
|
|
|
|
import org.springframework.messaging.handler.annotation.Header;
|
|
|
|
|