feat: do not accept records without request ID

README.md

@@ -69,6 +69,7 @@ Kafka-Records müssen eine(n)
 * **Header** mit Wert für`requestId` haben, damit eine ordnungsgemäße Zuordnung zu einer Anfrage im
   **mv64e-etl-processor** stattfinden kann.
   Ist dies nicht gegeben, kann die Rückantwort nicht einer eingehenden Anfrage zugeordnet werden.
+  Anfragen ohne `requestId` im Header werden abgelehnt.
 * **Payload** haben, die dem DNPM-Datenmodell 2.1 entspricht.
 
 Eine Prüfung auf MV- oder Forschungs-Consent findet nicht statt.

src/main.rs

@@ -151,7 +151,10 @@ async fn main() -> Result<(), Box<dyn Error>> {
             continue;
         };
 
-        let request_id = extract_request_id(&msg).unwrap_or_default();
+        let Some(request_id) = extract_request_id(&msg) else {
+            error!("Error getting request_id");
+            continue;
+        };
 
         match handle_record(payload).await {
             Err(err) => error!("{}", err),