This commit is contained in:
lee-soo-heon
2019-10-28 13:41:50 +09:00
parent 2eb86b2fe2
commit cb26411070

View File

@@ -25,7 +25,7 @@ public class OrderService {
/**
* 상품 변경이 발생할때마다, 상품정보를 저장해 놓음
*/
@KafkaListener(topics = "${eventTopic}")
@KafkaListener(topics = "${eventTopic}", groupId = "{{policy}}")
public void onDeliveryCompleted(@Payload String message, ConsumerRecord<?, ?> consumerRecord) {
System.out.println("##### listener : " + message);