diff --git a/server.js b/server.js
index 4805eec..b0a391e 100644
--- a/server.js
+++ b/server.js
@@ -51,19 +51,23 @@ io.on("connection", (socket) => {
   });
 
   socket.on("send_message", (data) => {
+    console.log("send_message", data.room);
     socket.to(data.room).emit("receive_message", data);
   });
 
   // to be removed 
   socket.on("marketjob", (data) => {
+    console.log("marketjob", data.room);
    socket.to(data.room).emit("marketjob_actions", data);
   });
 
   socket.on("marketjob_added", (data) => {
+    console.log("marketjob_added", data.room);    
     socket.to(data.room).emit("received_refreshmarket_jobs", data);
    });
 
     socket.on("family", (data) => {
+        console.log("family", data.room);
         socket.to(data.room).emit("family_actions", data);
     });
 
@@ -71,4 +75,6 @@ io.on("connection", (socket) => {
 
 server.listen(port, () => {
   console.log("SERVER IS RUNNING");
-});
\ No newline at end of file
+});
+
+//https://github.com/lemoncode21/nodejs-kafka/blob/master/index.js
\ No newline at end of file