diff --git a/src/Foundatio.Kafka/Messaging/KafkaMessageBus.cs b/src/Foundatio.Kafka/Messaging/KafkaMessageBus.cs index 3b88c9c..b46609f 100644 --- a/src/Foundatio.Kafka/Messaging/KafkaMessageBus.cs +++ b/src/Foundatio.Kafka/Messaging/KafkaMessageBus.cs @@ -266,6 +266,7 @@ private async Task EnsureTopicCreatedAsync() { topicSpecification.ReplicationFactor = _options.TopicReplicationFactor.Value; await adminClient.CreateTopicsAsync(new[] { topicSpecification }).AnyContext(); + await Task.Delay(TimeSpan.FromSeconds(2)); _topicCreated = true; if (_logger.IsEnabled(LogLevel.Trace)) diff --git a/tests/Foundatio.Kafka.Tests/Messaging/KafkaMessageBusFanOutTests.cs b/tests/Foundatio.Kafka.Tests/Messaging/KafkaMessageBusFanOutTests.cs index 83fa774..9c0be89 100644 --- a/tests/Foundatio.Kafka.Tests/Messaging/KafkaMessageBusFanOutTests.cs +++ b/tests/Foundatio.Kafka.Tests/Messaging/KafkaMessageBusFanOutTests.cs @@ -1,4 +1,4 @@ -using System; +using System; using System.Threading.Tasks; using Foundatio.Messaging; using Foundatio.Tests.Messaging; @@ -25,12 +25,12 @@ protected override IMessageBus GetMessageBus(Func