watson/umami
1
0
Fork 0
mirror of https://github.com/umami-software/umami.git synced 2026-02-18 19:45:35 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

fix: add website-event to kafka

Browse source
This commit is contained in:
harry 2024-11-27 11:42:29 +07:00
parent bc22ddec02
commit 10c4edc9ab
1 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

4
src/queries/analytics/events/saveEvent.ts
View file

@ -188,7 +188,7 @@ async function clickhouseQuery(data: {
...args ...args
} = data; } = data;
const { insert, getUTCString } = clickhouse; const { insert, getUTCString } = clickhouse;
const { sendMessage } = kafka; const { sendMessages } = kafka;
const createdAt = getUTCString(); const createdAt = getUTCString();
const websiteEventData = []; const websiteEventData = [];
@ -279,7 +279,7 @@ async function clickhouseQuery(data: {
} }
if (kafka.enabled) { if (kafka.enabled) {
await sendMessage('event', websiteEventData); await sendMessages('event', websiteEventData);
} else { } else {
await insert('website_event', websiteEventData); await insert('website_event', websiteEventData);
} }