Enhanced topic already exists condition

6 years ago · e9504c58ca
1 changed files with 1 additions and 1 deletions
--- a/framework/src/Volo.Abp.Kafka/Volo/Abp/Kafka/KafkaMessageConsumer.cs
+++ b/framework/src/Volo.Abp.Kafka/Volo/Abp/Kafka/KafkaMessageConsumer.cs
@ -86,7 +86,7 @@ namespace Volo.Abp.Kafka
                }
                catch (CreateTopicsException e)
                {
-                    if (!e.Error.Reason.Contains($"Topic '{TopicName}' already exists"))
+                    if(e.Results.First().Error.Code != ErrorCode.TopicAlreadyExists)
                    {
                        throw;
                    }