diff --git a/src/main/scala/ch/memobase/KProducer.scala b/src/main/scala/ch/memobase/KProducer.scala
index 2838401d51f4522f111a00811b3156546f04e6de..ea9808c53879abc2e0a0c39910c6464709a5d5d8 100644
--- a/src/main/scala/ch/memobase/KProducer.scala
+++ b/src/main/scala/ch/memobase/KProducer.scala
@@ -70,7 +70,7 @@ class KProducer(props: Properties, topic: String, reportTopic: String) extends L
 
   private def createHeaders(recordId: String): java.lang.Iterable[Header] = {
     val idPattern = "https://memobase.ch/([^/]+)/([^#/]+).*".r
-    val (recordSetId, institutionId) = idPattern.findFirstMatchIn(recordId) match {
+    val (institutionId, recordSetId) = idPattern.findFirstMatchIn(recordId) match {
       case Some(m) => m.groupCount match {
         case gc if gc >= 2 =>
           m.group(1) match {