diff --git a/src/main/java/com/example/template/Order.java b/src/main/java/com/example/template/Order.java index c5b943b..91363f3 100644 --- a/src/main/java/com/example/template/Order.java +++ b/src/main/java/com/example/template/Order.java @@ -81,7 +81,8 @@ public class Order { } // 2. 주문이 발생함 이벤트 발송 - ProducerRecord producerRecord = new ProducerRecord<>("eventTopic", json); + String topicName = env.getProperty("eventTopic"); + ProducerRecord producerRecord = new ProducerRecord<>(topicName, json); kafkaTemplate.send(producerRecord); }