diff --git a/src/queries/analytics/eventData/saveEventData.ts b/src/queries/analytics/eventData/saveEventData.ts index 490b15223..efe7ab51c 100644 --- a/src/queries/analytics/eventData/saveEventData.ts +++ b/src/queries/analytics/eventData/saveEventData.ts @@ -61,7 +61,7 @@ async function clickhouseQuery(data: { }) { const { websiteId, sessionId, visitId, eventId, urlPath, eventName, eventData, createdAt } = data; - const { getDateFormat, sendMessages, sendMessage } = kafka; + const { getDateFormat, sendMessages } = kafka; const jsonKeys = flattenJSON(eventData); @@ -101,7 +101,7 @@ async function clickhouseQuery(data: { message[`double${i + 1}`] = double; }); - await sendMessage(message, 'event_data_blob'); + // await sendMessage(message, 'event_data_blob'); return data; }