refactor: producer 기능에 영향 없는 코드 수정

-

Author: Kimjipang

apps/commerce-api/src/main/java/com/loopers/CommerceApiApplication.java

@@ -6,13 +6,15 @@
 import org.springframework.boot.context.properties.ConfigurationPropertiesScan;
 import org.springframework.cache.annotation.EnableCaching;
 import org.springframework.cloud.openfeign.EnableFeignClients;
+import org.springframework.scheduling.annotation.EnableScheduling;
 
 import java.util.TimeZone;
 
 @ConfigurationPropertiesScan
 @SpringBootApplication
 @EnableCaching
 @EnableFeignClients
+@EnableScheduling
 public class CommerceApiApplication {
 
     @PostConstruct

apps/commerce-api/src/main/java/com/loopers/domain/outbox/OutboxEvent.java

@@ -7,11 +7,13 @@
 import jakarta.persistence.Enumerated;
 import jakarta.persistence.Table;
 import lombok.AccessLevel;
+import lombok.Getter;
 import lombok.NoArgsConstructor;
 
 @Entity
 @Table(name = "outbox")
 @NoArgsConstructor(access = AccessLevel.PROTECTED)
+@Getter
 public class OutboxEvent extends BaseEntity {
     @Enumerated(EnumType.STRING)
     @Column(name = "aggregate_type", nullable = false)

apps/commerce-api/src/main/java/com/loopers/infrastructure/outbox/KafkaOutboxPublisher.java

@@ -20,14 +20,10 @@ public class KafkaOutboxPublisher {
     @Scheduled(fixedDelayString = "1000")
     @Transactional
     public void publish() {
-//        System.out.println("hello");
         List<OutboxEvent> events = outboxRepository.findPending(5);
-        for (OutboxEvent event : events) {
-            System.out.println("event.toString() = " + event.toString());
-        }
 
         for (OutboxEvent event : events) {
-            kafkaTemplate.send("product-viewed", event);
+            kafkaTemplate.send("product-viewed", String.valueOf(event.getAggregateId()), event);
 
             event.markAsProcessed();
         }