From c03949ac1555555b95aae78eca67a441477a2fdc Mon Sep 17 00:00:00 2001
From: MASES Public Developers Team
 <94312179+masesdevelopers@users.noreply.github.com>
Date: Thu, 27 Jun 2024 22:58:21 +0200
Subject: [PATCH] Return back to old code (#257)

---
 src/net/KEFCore/Storage/Internal/KafkaCluster.cs | 9 +--------
 1 file changed, 1 insertion(+), 8 deletions(-)

diff --git a/src/net/KEFCore/Storage/Internal/KafkaCluster.cs b/src/net/KEFCore/Storage/Internal/KafkaCluster.cs
index 9a75541..80dc5da 100644
--- 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++);