#82 (comment): Added a fixed limit to 10 iterations

masesgroup · Oct 11, 2023 · 73ebcba · 73ebcba
1 parent a330be0
commit 73ebcba
Showing 1 changed file with 9 additions and 3 deletions.
diff --git a/src/net/KEFCore/Storage/Internal/KafkaCluster.cs b/src/net/KEFCore/Storage/Internal/KafkaCluster.cs
@@ -179,8 +179,14 @@ public virtual bool EnsureConnected(
 
     public virtual string CreateTable(IEntityType entityType)
     {
-        var topicName = entityType.TopicName(Options);
+        return CreateTable(entityType, 0);
+    }
+
+    private string CreateTable(IEntityType entityType, int cycle)
+    {
+        if (cycle >= 10) throw new System.TimeoutException($"Timeout occurred executing CreateTable on {entityType.Name}");
 
+        var topicName = entityType.TopicName(Options);
         try
         {
             try
@@ -197,7 +203,7 @@ public virtual string CreateTable(IEntityType entityType)
                 var result = kafkaAdminClient.CreateTopics(coll);
                 result.All().Get();
             }
-            catch (Java.Util.Concurrent.ExecutionException ex)
+            catch (ExecutionException ex)
             {
                 throw ex.InnerException;
             }
@@ -207,7 +213,7 @@ public virtual string CreateTable(IEntityType entityType)
             if (ex.Message.Contains("deletion"))
             {
                 Thread.Sleep(1000); // wait a while to complete topic deletion and try again
-                return CreateTable(entityType);
+                return CreateTable(entityType, cycle++);
             }
         }
         return topicName;