diff --git a/modules/events/src/main/scala/io/renku/search/events/MessageHeader.scala b/modules/events/src/main/scala/io/renku/search/events/MessageHeader.scala
index d99164d4..f546527e 100644
--- a/modules/events/src/main/scala/io/renku/search/events/MessageHeader.scala
+++ b/modules/events/src/main/scala/io/renku/search/events/MessageHeader.scala
@@ -81,10 +81,10 @@ object MessageHeader:
   ): DataContentType =
     if (headerCt != decoded) {
       scribe.warn(
-        s"ContentType ($headerCt) used for decoding the header is not same as advertised in the header ($decoded)! Choose the one used for decoding the header to continue ($headerCt)."
+        s"ContentType ($headerCt) used for decoding the header is not same as advertised in the header ($decoded)! Choose the advertised format in the header to continue ($decoded)."
       )
     }
-    headerCt
+    decoded
 
   def fromByteVector(bv: ByteVector): Either[DecodeFailure, MessageHeader] =
     readBinaryOrJson(bv)