From cf76c059188b60fc4b0d754d6956139fed629ec8 Mon Sep 17 00:00:00 2001 From: kimscott Date: Mon, 2 Sep 2019 15:49:01 +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/Order.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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); }