Browse Source
Update framework/src/Volo.Abp.EventBus.Kafka/Volo/Abp/EventBus/Kafka/KafkaDistributedEventBus.cs
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>
pull/24350/head
Ma Liming
2 months ago
committed by
GitHub
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with
1 additions and
1 deletions
-
framework/src/Volo.Abp.EventBus.Kafka/Volo/Abp/EventBus/Kafka/KafkaDistributedEventBus.cs
|
|
|
@ -308,7 +308,7 @@ public class KafkaDistributedEventBus : DistributedEventBusBase, ISingletonDepen |
|
|
|
var result = await PublishAsync(topicName, eventName, body, headers); |
|
|
|
if (result.Status != PersistenceStatus.Persisted) |
|
|
|
{ |
|
|
|
throw new AbpException($"Failed to publish event '{eventName}' to topic '{topicName}'."); |
|
|
|
throw new AbpException($"Failed to publish event '{eventName}' to topic '{topicName}'. Status: {result.Status}"); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
