Hello,
https://docs.abp.io/en/abp/7.1/Distributed-Event-Bus#enabling-event-outbox
I followed the "Enabling event outbox", but when sending events, regardless of whether the Kafka server is connected properly or not, the events are not being written to the database.
EF Core table: AbpEventOutbox MongoDB table: OutgoingEvents
log: (stop the kafka server) [14:25:04 INF] Found 1 events in the outbox. [14:25:04 INF] Sent 1 events to message broker
I want to set it up so that when the Kafka connection is abnormal, events can be written to the outbox table. Then, when the connection is restored, the events can be sent out again.
- ABP Framework version: v7.1.1
- UI Type: Flutter
- Database System: EF Core (SQL Server) / MongoDB
- Tiered (for MVC) or Auth Server Separated (for Angular):
- Exception message and full stack trace:
- Steps to reproduce the issue:
4 Answer(s)
-
0
In my local test, why is the event written to the outbox table only when I set "BatchPublishOutboxEvents" to false?
-
0
hi
How can I reproduce your problem in a new template project?
Can you share the steps and code or a simple project?
Thanks
-
0
-
0
Records are deleted after they are published to the event bus.