Fixed kafka producer exception log without logging when publish message.

src/DotNetCore.CAP.Kafka/IPublishMessageSender.Kafka.cs

@@ -36,11 +36,7 @@ namespace DotNetCore.CAP.Kafka
 
                 if (message.Error.HasError)
                 {
-                    return OperateResult.Failed(new OperateError
-                    {
-                        Code = message.Error.Code.ToString(),
-                        Description = message.Error.Reason
-                    });
+                    throw new PublisherSentFailedException(message.Error.ToString());
                 }
 
                 _logger.LogDebug($"kafka topic message [{keyName}] has been published.");
@@ -61,6 +57,6 @@ namespace DotNetCore.CAP.Kafka
                     producer.Dispose();
                 }
             }
-        } 
+        }
     }
 }

src/DotNetCore.CAP/Infrastructure/Helper.cs

@@ -86,7 +86,6 @@ namespace DotNetCore.CAP.Infrastructure
             return !CanConvertFromString(type);
         }
 
-
         public static string AddExceptionProperty(string json, Exception exception)
         {
             var jObject = ToJObject(exception);