Merge remote-tracking branch 'origin/master'

This commit is contained in:
kimscott
2019-10-29 14:24:58 +09:00

View File

@@ -27,6 +27,7 @@ public class OrderService {
/**
* 상품 변경이 발생할때마다, 상품정보를 저장해 놓음
*/
@StreamListener(KafkaProcessor.INPUT)
public void onProductChanged(@Payload String message) {
System.out.println("##### listener : " + message);