From 10c4edc9ab92856985805a0b8cdb993f9d8f8d26 Mon Sep 17 00:00:00 2001
From: harry <manhduong240101@gmail.com>
Date: Wed, 27 Nov 2024 11:42:29 +0700
Subject: [PATCH] fix: add website-event to kafka

---
 src/queries/analytics/events/saveEvent.ts | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/queries/analytics/events/saveEvent.ts b/src/queries/analytics/events/saveEvent.ts
index 5a2fe9290..dfefcc547 100644
--- a/src/queries/analytics/events/saveEvent.ts
+++ b/src/queries/analytics/events/saveEvent.ts
@@ -188,7 +188,7 @@ async function clickhouseQuery(data: {
     ...args
   } = data;
   const { insert, getUTCString } = clickhouse;
-  const { sendMessage } = kafka;
+  const { sendMessages } = kafka;
   const createdAt = getUTCString();
 
   const websiteEventData = [];
@@ -279,7 +279,7 @@ async function clickhouseQuery(data: {
   }
 
   if (kafka.enabled) {
-    await sendMessage('event', websiteEventData);
+    await sendMessages('event', websiteEventData);
   } else {
     await insert('website_event', websiteEventData);
   }