topicname 일괄 변경

This commit is contained in:
kimscott
2019-09-02 15:49:01 +09:00
parent b149b195c0
commit cf76c05918

View File

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