This commit is contained in:
Viet-Tien Ngoc 2024-08-06 11:44:17 +07:00
parent 0c8894a13b
commit e6c646e4c8
2 changed files with 9 additions and 44 deletions

View file

@ -61,7 +61,7 @@ async function clickhouseQuery(data: {
}) {
const { websiteId, sessionId, visitId, eventId, urlPath, eventName, eventData, createdAt } = data;
const { getDateFormat, sendMessages } = kafka;
const { getDateFormat, sendMessages, sendMessage } = 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;
}