diff --git a/store/src/main/java/com/ktds/hi/store/biz/service/ExternalIntegrationInteractor.java b/store/src/main/java/com/ktds/hi/store/biz/service/ExternalIntegrationInteractor.java index e4b39a9..a6a85b4 100644 --- a/store/src/main/java/com/ktds/hi/store/biz/service/ExternalIntegrationInteractor.java +++ b/store/src/main/java/com/ktds/hi/store/biz/service/ExternalIntegrationInteractor.java @@ -4,6 +4,7 @@ import com.azure.messaging.eventhubs.EventData; import com.azure.messaging.eventhubs.EventDataBatch; import com.azure.messaging.eventhubs.EventHubClientBuilder; import com.azure.messaging.eventhubs.EventHubProducerClient; +import com.azure.messaging.eventhubs.models.CreateBatchOptions; import com.azure.messaging.eventhubs.models.SendOptions; import com.fasterxml.jackson.databind.ObjectMapper; import com.ktds.hi.store.biz.usecase.in.ExternalIntegrationUseCase; @@ -253,11 +254,10 @@ public class ExternalIntegrationInteractor implements ExternalIntegrationUseCase EventData eventData = new EventData(payloadJson); - // πŸ”₯ νŒŒν‹°μ…˜ 4λ²ˆμ— 보내기 μœ„ν•œ SendOptions μ„€μ • - SendOptions sendOptions = new SendOptions(); - sendOptions.setPartitionId("4"); - // EventDataBatch μ‚¬μš© - EventDataBatch batch = producer.createBatch(); + CreateBatchOptions batchOptions = new CreateBatchOptions(); + batchOptions.setPartitionId("4"); // 배치 μ „μ²΄μ˜ νŒŒν‹°μ…˜ κ³ μ • + + EventDataBatch batch = producer.createBatch(batchOptions); // μ˜΅μ…˜ 적용된 배치 생성 if (batch.tryAdd(eventData)) { producer.send(batch); log.info("동기화 이벀트 λ°œν–‰ 성곡: storeId={}, platform={}, syncedCount={}",