From ed62dd63229e2a772ba9ee68cfff2b84251395bc Mon Sep 17 00:00:00 2001
From: Ma Liming <malimings@gmail.com>
Date: Sun, 7 Dec 2025 13:28:37 +0800
Subject: [PATCH] Update
 framework/src/Volo.Abp.EventBus.Kafka/Volo/Abp/EventBus/Kafka/KafkaDistributedEventBus.cs

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>
---
 .../Volo/Abp/EventBus/Kafka/KafkaDistributedEventBus.cs         | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/framework/src/Volo.Abp.EventBus.Kafka/Volo/Abp/EventBus/Kafka/KafkaDistributedEventBus.cs b/framework/src/Volo.Abp.EventBus.Kafka/Volo/Abp/EventBus/Kafka/KafkaDistributedEventBus.cs
index 8e9d012d7f..f9f93c755c 100644
--- a/framework/src/Volo.Abp.EventBus.Kafka/Volo/Abp/EventBus/Kafka/KafkaDistributedEventBus.cs
+++ b/framework/src/Volo.Abp.EventBus.Kafka/Volo/Abp/EventBus/Kafka/KafkaDistributedEventBus.cs
@@ -258,7 +258,7 @@ public class KafkaDistributedEventBus : DistributedEventBusBase, ISingletonDepen
 
             if (result.Status != PersistenceStatus.Persisted)
             {
-                throw new AbpException($"Failed to publish event '{outgoingEvent.EventName}' to topic '{AbpKafkaEventBusOptions.TopicName}'.");
+                throw new AbpException($"Failed to publish event '{outgoingEvent.EventName}' to topic '{AbpKafkaEventBusOptions.TopicName}'. Status: {result.Status}");
             }
 
             using (CorrelationIdProvider.Change(outgoingEvent.GetCorrelationId()))