YAR-14287: cast kafka key to string bc of kafkajs limitation (Materia…

…lizeInc#48)
recursethis · Feb 12, 2024 · fdba6de · fdba6de
1 parent 6cefb6d
commit fdba6de
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/src/kafka/producer.js b/src/kafka/producer.js
@@ -19,6 +19,10 @@ module.exports = async (recordKey = null, record, encodedRecord = null, topic =
         payload = JSON.stringify(record);
     }
 
+    if (recordKey !== null) {
+        recordKey = recordKey.toString();
+    }
+
     await producer.send({
         topic: topic,
         messages: [{