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<? extends NotificationMessage> items) {
                 String key = String.valueOf(event.subscriptionInfo().get("subId"));
 
                 CompletableFuture<SendResult<String, String>> 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<InvoiceAggregateRecord>, ItemStream {
 
-    private static final String TOPIC = "invoice-noti";
+    private static final String TOPIC = "invoice";
 
     private final KafkaTemplate<String, String> kafkaTemplate;
     private final ObjectMapper objectMapper;