From af48eb2528812df3acab350702e91070c4f31ef7 Mon Sep 17 00:00:00 2001
From: UNGGU0704 <kyuhung1001@gmail.com>
Date: Thu, 19 Jun 2025 16:04:40 +0900
Subject: [PATCH] =?UTF-8?q?Fix:=20Eventhub=20=ED=8C=8C=ED=8B=B0=EC=85=98?=
 =?UTF-8?q?=20=EA=B3=A0=EC=A0=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../biz/service/ExternalIntegrationInteractor.java     | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

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={}",