diff --git a/src/main/kotlin/no/digdir/fdk/mqa/dcatvalidator/kafka/KafkaMqaEventProducer.kt b/src/main/kotlin/no/digdir/fdk/mqa/dcatvalidator/kafka/KafkaMqaEventProducer.kt
index ed11f1d..f33a37a 100644
--- a/src/main/kotlin/no/digdir/fdk/mqa/dcatvalidator/kafka/KafkaMqaEventProducer.kt
+++ b/src/main/kotlin/no/digdir/fdk/mqa/dcatvalidator/kafka/KafkaMqaEventProducer.kt
@@ -13,7 +13,7 @@ class KafkaMqaEventProducer(
     private val kafkaTemplate: KafkaTemplate<String, MQAEvent>
 ) {
     fun sendMQAEvent(mqaEvent: MQAEvent) {
-        kafkaTemplate.send("mqa-events", mqaEvent).handle { result, exception ->
+        kafkaTemplate.send("mqa-events", mqaEvent.fdkId.toString(), mqaEvent).handle { result, exception ->
             if (exception != null) {
                 LOGGER.error("Error sending MQA event: " + exception.message)
                 Metrics.counter("produced_messages", "status", "error").increment()