Return back to old code (#257)

masesgroup · Jun 27, 2024 · c03949a · c03949a
1 parent d7a87ab
commit c03949a
Showing 1 changed file with 1 addition and 8 deletions.
diff --git a/src/net/KEFCore/Storage/Internal/KafkaCluster.cs b/src/net/KEFCore/Storage/Internal/KafkaCluster.cs
@@ -228,14 +228,7 @@ private string CreateTable(IEntityType entityType, int cycle)
         }
         catch (TopicExistsException ex)
         {
-            string message;
-            if (ex.BridgeInstance == null && ex is JVMBridgeException ex2)
-            {
-                message = ex2.Message;
-            }
-            else message = ex.Message;
-
-            if (message.Contains("deletion"))
+            if (ex.Message.Contains("deletion"))
             {
                 Thread.Sleep(1000); // wait a while to complete topic deletion and try again
                 return CreateTable(entityType, cycle++);