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++);