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);