ABP Framework version: ABP CLI 7.3.0 UI Type: Blazor Server Database System: EF Core (SQL Server) Tiered (for MVC) or Auth Server Separated (for Angular): Tiered Exception message and full stack trace:
Query: Kafka has been enabled at entity level. Upon successful DB save operation if kafka messaging service is unavailable below exception occurs and save process fails. How to avoid save process failure and show user success message? How to delink kafka process from save process?
Logs: 2023-08-30 09:52:27.773 +05:30 [DBG] Added 1 entity changes to the current audit log 2023-08-30 09:52:28.070 +05:30 [INF] Executing ObjectResult, writing value of type 'Inventory.LocationDto'. 2023-08-30 09:52:28.072 +05:30 [INF] Executed action Inventory.Locations.LocationAppService.AddLocation (Inventory.Application) in 1473.7394ms 2023-08-30 09:52:28.072 +05:30 [INF] Executed endpoint 'Inventory.Locations.LocationAppService.AddLocation (Inventory.Application)' 2023-08-30 09:52:28.073 +05:30 [DBG] Added 0 entity changes to the current audit log 2023-08-30 09:52:51.159 +05:30 [ERR] Failed while waiting for controller: Local: Timed out Confluent.Kafka.KafkaException: Failed while waiting for controller: Local: Timed out at Volo.Abp.Kafka.KafkaMessageConsumer.CreateTopicAsync() at Volo.Abp.Kafka.KafkaMessageConsumer.Timer_Elapsed(AbpAsyncTimer timer) at Volo.Abp.Threading.AbpAsyncTimer.Timer_Elapsed() 2023-08-30 09:53:56.980 +05:30 [ERR] Failed while waiting for controller: Local: Timed out Confluent.Kafka.KafkaException: Failed while waiting for controller: Local: Timed out at Volo.Abp.Kafka.KafkaMessageConsumer.CreateTopicAsync() at Volo.Abp.Kafka.KafkaMessageConsumer.Timer_Elapsed(AbpAsyncTimer timer) at Volo.Abp.Threading.AbpAsyncTimer.Timer_Elapsed()
1 Answer(s)
-
0
hi
This is designed. It would be best to ensure the service is always available.