From 51802bd61a923b0cc9a614cbf058819c88d0f781 Mon Sep 17 00:00:00 2001
From: chgl <chgl@users.noreply.github.com>
Date: Sun, 30 May 2021 18:05:22 +0200
Subject: [PATCH] fix: store the error description in message headers for the
 DLQ

---
 ahd2fhir/kafka_setup.py | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/ahd2fhir/kafka_setup.py b/ahd2fhir/kafka_setup.py
index 398ad62..7ea0973 100644
--- a/ahd2fhir/kafka_setup.py
+++ b/ahd2fhir/kafka_setup.py
@@ -132,8 +132,12 @@ async def send_consumer_message(consumer):  # pragma: no cover
                 failed_topic=failed_topic,
             )
 
+            headers = [("error", f"Mapping Error: {exc}".encode("utf8"))]
+
             try:
-                await producer.send_and_wait(failed_topic, msg.value)
+                await producer.send_and_wait(
+                    failed_topic, msg.value, key=msg.key, headers=headers
+                )
             except Exception as error_topic_exc:
                 logger.error(
                     f"Failed to send message to error topic: {error_topic_exc}"