diff --git a/src/SlimMessageBus.Host.Kafka/KafkaMessageBus.cs b/src/SlimMessageBus.Host.Kafka/KafkaMessageBus.cs
index 8dd76819..f796192b 100644
--- a/src/SlimMessageBus.Host.Kafka/KafkaMessageBus.cs
+++ b/src/SlimMessageBus.Host.Kafka/KafkaMessageBus.cs
@@ -154,7 +154,7 @@ protected override async Task ProduceToTransport(object message, string path, by
         var deliveryResult = await task.ConfigureAwait(false);
         if (deliveryResult.Status == PersistenceStatus.NotPersisted)
         {
-            throw new ProducerMessageBusException($"Error while publish message {message} of type {messageType.Name} to topic {path}. Kafka persistence status: {deliveryResult.Status}");
+            throw new ProducerMessageBusException($"Error while publish message {message} of type {messageType?.Name} to topic {path}. Kafka persistence status: {deliveryResult.Status}");
         }
 
         // log some debug information