From 7bf7a2be1c7189da6f9b8a60a138637e80bd1de3 Mon Sep 17 00:00:00 2001
From: Kartheek Palla <palla.kartheekreddy@gmail.com>
Date: Thu, 25 Nov 2021 14:59:31 +0530
Subject: [PATCH] Issue #SB-000 fix: key added for kafka event
---
src/helpers/kafkaUtil.js | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/src/helpers/kafkaUtil.js b/src/helpers/kafkaUtil.js
index 9e7381e..4ca49d7 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}})
--
GitLab