diff --git a/src/main/java/org/miracum/streams/ume/obdstofhir/mapper/ObdsToFhirMapper.java b/src/main/java/org/miracum/streams/ume/obdstofhir/mapper/ObdsToFhirMapper.java
index 9a108e79..357389e6 100644
--- a/src/main/java/org/miracum/streams/ume/obdstofhir/mapper/ObdsToFhirMapper.java
+++ b/src/main/java/org/miracum/streams/ume/obdstofhir/mapper/ObdsToFhirMapper.java
@@ -111,7 +111,7 @@ public static String getPatIdFromMeldung(MeldungExport meldung) {
         .getPatient_ID();
   }
 
-  public static String getTumorIdFromAdt(MeldungExport meldung) {
+  public static String getTumorIdFromMeldung(MeldungExport meldung) {
     return meldung
         .getXml_daten()
         .getMenge_Patient()
diff --git a/src/main/java/org/miracum/streams/ume/obdstofhir/processor/ObdsProcessor.java b/src/main/java/org/miracum/streams/ume/obdstofhir/processor/ObdsProcessor.java
index 0e92874a..24eed6b5 100644
--- a/src/main/java/org/miracum/streams/ume/obdstofhir/processor/ObdsProcessor.java
+++ b/src/main/java/org/miracum/streams/ume/obdstofhir/processor/ObdsProcessor.java
@@ -83,7 +83,7 @@ protected ObdsProcessor(
                           "Struct{REFERENZ_NUMMER="
                               + getPatIdFromMeldung(meldung)
                               + ",TUMOR_ID="
-                              + getTumorIdFromAdt(meldung)
+                              + getTumorIdFromMeldung(meldung)
                               + "}",
                           meldung),
                   Grouped.with(Serdes.String(), new MeldungExportSerde()))