From a590639fa70ad8f148708807e2bbabf4a388d56d Mon Sep 17 00:00:00 2001 From: andrew Date: Mon, 26 Jan 2026 22:57:04 +0900 Subject: [PATCH] =?UTF-8?q?UPLUS-154=20fix=20:=20topic=20=EC=88=98?= =?UTF-8?q?=EC=A0=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../batch/notificationsend/writer/NotificationSendWriter.java | 2 +- .../worker/jobs/invoicesend/writer/InvoiceSendWriter.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/template/worker/batch/notificationsend/writer/NotificationSendWriter.java b/src/main/java/com/template/worker/batch/notificationsend/writer/NotificationSendWriter.java index e0ebfcf..97cb95d 100644 --- a/src/main/java/com/template/worker/batch/notificationsend/writer/NotificationSendWriter.java +++ b/src/main/java/com/template/worker/batch/notificationsend/writer/NotificationSendWriter.java @@ -48,7 +48,7 @@ public void write(Chunk items) { String key = String.valueOf(event.subscriptionInfo().get("subId")); CompletableFuture> future = - kafkaTemplate.send("usage-noti", key, payload); + kafkaTemplate.send("usage", key, payload); tasks.add(new NotificationSendTask(event, future)); } catch (Exception e) { diff --git a/src/main/java/com/template/worker/jobs/invoicesend/writer/InvoiceSendWriter.java b/src/main/java/com/template/worker/jobs/invoicesend/writer/InvoiceSendWriter.java index b0ba2a8..406265a 100644 --- a/src/main/java/com/template/worker/jobs/invoicesend/writer/InvoiceSendWriter.java +++ b/src/main/java/com/template/worker/jobs/invoicesend/writer/InvoiceSendWriter.java @@ -18,7 +18,7 @@ @RequiredArgsConstructor public class InvoiceSendWriter implements ItemWriter, ItemStream { - private static final String TOPIC = "invoice-noti"; + private static final String TOPIC = "invoice"; private final KafkaTemplate kafkaTemplate; private final ObjectMapper objectMapper;