diff --git a/src/Transports/Kafka/Wolverine.Kafka/Internals/KafkaEnvelopeMapper.cs b/src/Transports/Kafka/Wolverine.Kafka/Internals/KafkaEnvelopeMapper.cs
index 0e661191a..8aa5a20d2 100644
--- a/src/Transports/Kafka/Wolverine.Kafka/Internals/KafkaEnvelopeMapper.cs
+++ b/src/Transports/Kafka/Wolverine.Kafka/Internals/KafkaEnvelopeMapper.cs
@@ -28,4 +28,15 @@ protected override bool tryReadIncomingHeader(Message<string, byte[]> incoming,
         value = default!;
         return false;
     }
+
+    protected override void writeIncomingHeaders(Message<string, byte[]> incoming, Envelope envelope)
+    {
+        if (incoming.Headers == null) return;
+        foreach (var header in incoming.Headers)
+        {
+            var bytes = header.GetValueBytes();
+            envelope.Headers[header.Key] = bytes != null ? Encoding.Default.GetString(bytes) : null;
+        }
+    }
+
 }
\ No newline at end of file