From 4badc0e3abf679659406a2279cfcc7cd7b034f0e Mon Sep 17 00:00:00 2001 From: kimscott Date: Mon, 2 Sep 2019 15:49:00 +0900 Subject: [PATCH] =?UTF-8?q?topicname=20=EC=9D=BC=EA=B4=84=20=EB=B3=80?= =?UTF-8?q?=EA=B2=BD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/java/com/example/template/Product.java | 5 ++++- src/main/java/com/example/template/ProductService.java | 2 +- 2 files changed, 5 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/example/template/Product.java b/src/main/java/com/example/template/Product.java index 79e3480..0532c09 100644 --- a/src/main/java/com/example/template/Product.java +++ b/src/main/java/com/example/template/Product.java @@ -4,6 +4,7 @@ import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.databind.ObjectMapper; import org.apache.kafka.clients.producer.ProducerRecord; import org.springframework.beans.BeanUtils; +import org.springframework.core.env.Environment; import org.springframework.kafka.core.KafkaTemplate; import javax.persistence.*; @@ -38,7 +39,9 @@ public class Product { } if( json != null ){ - ProducerRecord producerRecord = new ProducerRecord<>("eventTopic", json); + Environment env = Application.applicationContext.getEnvironment(); + String topicName = env.getProperty("eventTopic"); + ProducerRecord producerRecord = new ProducerRecord<>(topicName, json); kafkaTemplate.send(producerRecord); } } diff --git a/src/main/java/com/example/template/ProductService.java b/src/main/java/com/example/template/ProductService.java index d7b44f9..fb92b8c 100644 --- a/src/main/java/com/example/template/ProductService.java +++ b/src/main/java/com/example/template/ProductService.java @@ -18,7 +18,7 @@ public class ProductService { @Autowired ProductRepository productRepository; - @KafkaListener(topics = "eventTopic") + @KafkaListener(topics = "${eventTopic}") public void onListener(@Payload String message, ConsumerRecord consumerRecord) { System.out.println("##### listener : " + message);