diff --git a/src/helpers/kafkaUtil.js b/src/helpers/kafkaUtil.js
index 9e7381ee028d26be127ef75efd6967ee91e074c4..4ca49d7f1453a78c01183e57aca446a114dec029 100644
--- a/src/helpers/kafkaUtil.js
+++ b/src/helpers/kafkaUtil.js
@@ -47,7 +47,8 @@ const KafkaService = {
     const record = [
       {
         topic: topicName,
-        messages: JSON.stringify(data)
+        messages: JSON.stringify(data),
+        key: data.processId
       }
     ]
     logger.info({msg: 'Kafka record', additionalInfo: {record}})