fix: use fdkId as key to make sure all events of the same resource ar…

…e stored in the same partition
Informasjonsforvaltning · Nov 22, 2024 · d4407f2 · d4407f2
1 parent 8b0302e
commit d4407f2
Showing 1 changed file with 1 addition and 1 deletion.
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
@@ -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()