fix send message. look at redis on session create

queries/analytics/event/saveEvent.js

@@ -62,5 +62,5 @@ async function kafkaQuery(website_id, { event_uuid, session_uuid, url, event_nam
     event_name: event_name?.substr(0, 50),
   };
 
-  await kafka.sendKafkaMessage(params, 'event');
+  await kafka.sendMessage(params, 'event');
 }

queries/analytics/pageview/savePageView.js

@@ -50,5 +50,5 @@ async function kafkaQuery(website_id, { session_uuid, url, referrer }) {
     referrer: referrer?.substr(0, URL_LENGTH),
   };
 
-  await kafka.sendKafkaMessage(params, 'pageview');
+  await kafka.sendMessage(params, 'pageview');
 }

queries/analytics/session/createSession.js

@@ -73,7 +73,7 @@ async function kafkaQuery(
     country: country ? country : null,
   };
 
-  await kafka.sendKafkaMessage(params, 'session');
+  await kafka.sendMessage(params, 'session');
 
   await redis.set(`session:${session_uuid}`, '');
 }