changes for #2

Author: veshu

utils/kafka.js

@@ -25,7 +25,21 @@ class Kafka {
   }
 
   send(message) {
-    return this.producer.send({topic: config.TOPIC, message: {value: message}});
+    const data = JSON.stringify({
+      topic: config.TOPIC,
+      originator: 'topcoder-x-receiver',
+      timestamp: (new Date()).toISOString(),
+      'mime-type': 'application/json',
+      payload: {
+        value: message
+      }
+    });
+    return this.producer.send({
+      topic: config.TOPIC,
+      message: {
+        value: data
+      }
+    });
   }
 }