diff --git a/src/Silverback.Integration.MQTT/Messaging/Broker/Mqtt/ConsumedApplicationMessage.cs b/src/Silverback.Integration.MQTT/Messaging/Broker/Mqtt/ConsumedApplicationMessage.cs
index f5c7a6141..c1d20fe50 100644
--- a/src/Silverback.Integration.MQTT/Messaging/Broker/Mqtt/ConsumedApplicationMessage.cs
+++ b/src/Silverback.Integration.MQTT/Messaging/Broker/Mqtt/ConsumedApplicationMessage.cs
@@ -15,9 +15,7 @@ internal sealed class ConsumedApplicationMessage
         public ConsumedApplicationMessage(MqttApplicationMessageReceivedEventArgs eventArgs)
         {
             EventArgs = eventArgs;
-            Id = eventArgs.ApplicationMessage.UserProperties
-                     ?.FirstOrDefault(header => header.Name == DefaultMessageHeaders.MessageId)?.Value
-                 ?? Guid.NewGuid().ToString();
+            Id = Guid.NewGuid().ToString();
         }
 
         public string Id { get; }