diff --git a/src/main/kotlin/KafkaTopology.kt b/src/main/kotlin/KafkaTopology.kt
index 6da892889daadcad08b8f458d27cccd4cdb858f8..3d51624987806d207ed6668b81f62181b60796dc 100644
--- a/src/main/kotlin/KafkaTopology.kt
+++ b/src/main/kotlin/KafkaTopology.kt
@@ -111,7 +111,7 @@ class KafkaTopology(
                     }
 
                     var producerRecord: ProducerRecord<String, String> =
-                        ProducerRecord(outputTopic, event.eventId, modelString)
+                        ProducerRecord(outputTopic, it.key(), modelString)
                     if (headerData.containsKey("institutionId")) {
                         producerRecord.headers().add("institutionId", headerData["institutionId"]?.toByteArray())
                     }