diff --git a/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaCluster.html b/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaCluster.html
index 5cd92543..d4cd03e4 100644
--- a/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaCluster.html
+++ b/docs/api/MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaCluster.html
@@ -228,7 +228,7 @@ <h3 id="methods">Methods
     <a href="https://github.com/masesgroup/KEFCore/new/master/apiSpec/new?filename=MASES_EntityFrameworkCore_KNet_Storage_Internal_KafkaCluster_CreateCompactedReplicator_IEntityType_.md&amp;value=---%0Auid%3A%20MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaCluster.CreateCompactedReplicator(IEntityType)%0Asummary%3A%20'*You%20can%20override%20summary%20for%20the%20API%20here%20using%20*MARKDOWN*%20syntax'%0A---%0A%0A*Please%20type%20below%20more%20information%20about%20this%20API%3A*%0A%0A">Improve this Doc</a>
   </span>
   <span class="small pull-right mobile-hide">
-    <a href="https://github.com/masesgroup/KEFCore/blob/master/src/net/KEFCore/Storage/Internal/KafkaCluster.cs/#L214">View Source</a>
+    <a href="https://github.com/masesgroup/KEFCore/blob/master/src/net/KEFCore/Storage/Internal/KafkaCluster.cs/#L224">View Source</a>
   </span>
   <a id="MASES_EntityFrameworkCore_KNet_Storage_Internal_KafkaCluster_CreateCompactedReplicator_" data-uid="MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaCluster.CreateCompactedReplicator*"></a>
   <h4 id="MASES_EntityFrameworkCore_KNet_Storage_Internal_KafkaCluster_CreateCompactedReplicator_IEntityType_" data-uid="MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaCluster.CreateCompactedReplicator(IEntityType)">CreateCompactedReplicator(IEntityType)</h4>
@@ -275,7 +275,7 @@ <h5 class="returns">Returns</h5>
     <a href="https://github.com/masesgroup/KEFCore/new/master/apiSpec/new?filename=MASES_EntityFrameworkCore_KNet_Storage_Internal_KafkaCluster_CreateProducer_IEntityType_.md&amp;value=---%0Auid%3A%20MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaCluster.CreateProducer(IEntityType)%0Asummary%3A%20'*You%20can%20override%20summary%20for%20the%20API%20here%20using%20*MARKDOWN*%20syntax'%0A---%0A%0A*Please%20type%20below%20more%20information%20about%20this%20API%3A*%0A%0A">Improve this Doc</a>
   </span>
   <span class="small pull-right mobile-hide">
-    <a href="https://github.com/masesgroup/KEFCore/blob/master/src/net/KEFCore/Storage/Internal/KafkaCluster.cs/#L232">View Source</a>
+    <a href="https://github.com/masesgroup/KEFCore/blob/master/src/net/KEFCore/Storage/Internal/KafkaCluster.cs/#L242">View Source</a>
   </span>
   <a id="MASES_EntityFrameworkCore_KNet_Storage_Internal_KafkaCluster_CreateProducer_" data-uid="MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaCluster.CreateProducer*"></a>
   <h4 id="MASES_EntityFrameworkCore_KNet_Storage_Internal_KafkaCluster_CreateProducer_IEntityType_" data-uid="MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaCluster.CreateProducer(IEntityType)">CreateProducer(IEntityType)</h4>
@@ -322,7 +322,7 @@ <h5 class="returns">Returns</h5>
     <a href="https://github.com/masesgroup/KEFCore/new/master/apiSpec/new?filename=MASES_EntityFrameworkCore_KNet_Storage_Internal_KafkaCluster_CreateSerdes_IEntityType_.md&amp;value=---%0Auid%3A%20MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaCluster.CreateSerdes(IEntityType)%0Asummary%3A%20'*You%20can%20override%20summary%20for%20the%20API%20here%20using%20*MARKDOWN*%20syntax'%0A---%0A%0A*Please%20type%20below%20more%20information%20about%20this%20API%3A*%0A%0A">Improve this Doc</a>
   </span>
   <span class="small pull-right mobile-hide">
-    <a href="https://github.com/masesgroup/KEFCore/blob/master/src/net/KEFCore/Storage/Internal/KafkaCluster.cs/#L212">View Source</a>
+    <a href="https://github.com/masesgroup/KEFCore/blob/master/src/net/KEFCore/Storage/Internal/KafkaCluster.cs/#L222">View Source</a>
   </span>
   <a id="MASES_EntityFrameworkCore_KNet_Storage_Internal_KafkaCluster_CreateSerdes_" data-uid="MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaCluster.CreateSerdes*"></a>
   <h4 id="MASES_EntityFrameworkCore_KNet_Storage_Internal_KafkaCluster_CreateSerdes_IEntityType_" data-uid="MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaCluster.CreateSerdes(IEntityType)">CreateSerdes(IEntityType)</h4>
@@ -369,7 +369,7 @@ <h5 class="returns">Returns</h5>
     <a href="https://github.com/masesgroup/KEFCore/new/master/apiSpec/new?filename=MASES_EntityFrameworkCore_KNet_Storage_Internal_KafkaCluster_CreateTable_IEntityType_.md&amp;value=---%0Auid%3A%20MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaCluster.CreateTable(IEntityType)%0Asummary%3A%20'*You%20can%20override%20summary%20for%20the%20API%20here%20using%20*MARKDOWN*%20syntax'%0A---%0A%0A*Please%20type%20below%20more%20information%20about%20this%20API%3A*%0A%0A">Improve this Doc</a>
   </span>
   <span class="small pull-right mobile-hide">
-    <a href="https://github.com/masesgroup/KEFCore/blob/master/src/net/KEFCore/Storage/Internal/KafkaCluster.cs/#L180">View Source</a>
+    <a href="https://github.com/masesgroup/KEFCore/blob/master/src/net/KEFCore/Storage/Internal/KafkaCluster.cs/#L190">View Source</a>
   </span>
   <a id="MASES_EntityFrameworkCore_KNet_Storage_Internal_KafkaCluster_CreateTable_" data-uid="MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaCluster.CreateTable*"></a>
   <h4 id="MASES_EntityFrameworkCore_KNet_Storage_Internal_KafkaCluster_CreateTable_IEntityType_" data-uid="MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaCluster.CreateTable(IEntityType)">CreateTable(IEntityType)</h4>
@@ -431,7 +431,7 @@ <h5 class="decalaration">Declaration</h5>
     <a href="https://github.com/masesgroup/KEFCore/new/master/apiSpec/new?filename=MASES_EntityFrameworkCore_KNet_Storage_Internal_KafkaCluster_EnsureConnected_IModel_IDiagnosticsLogger_DbLoggerCategory_Update__.md&amp;value=---%0Auid%3A%20MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaCluster.EnsureConnected(IModel%2CIDiagnosticsLogger%7BDbLoggerCategory.Update%7D)%0Asummary%3A%20'*You%20can%20override%20summary%20for%20the%20API%20here%20using%20*MARKDOWN*%20syntax'%0A---%0A%0A*Please%20type%20below%20more%20information%20about%20this%20API%3A*%0A%0A">Improve this Doc</a>
   </span>
   <span class="small pull-right mobile-hide">
-    <a href="https://github.com/masesgroup/KEFCore/blob/master/src/net/KEFCore/Storage/Internal/KafkaCluster.cs/#L173">View Source</a>
+    <a href="https://github.com/masesgroup/KEFCore/blob/master/src/net/KEFCore/Storage/Internal/KafkaCluster.cs/#L183">View Source</a>
   </span>
   <a id="MASES_EntityFrameworkCore_KNet_Storage_Internal_KafkaCluster_EnsureConnected_" data-uid="MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaCluster.EnsureConnected*"></a>
   <h4 id="MASES_EntityFrameworkCore_KNet_Storage_Internal_KafkaCluster_EnsureConnected_IModel_IDiagnosticsLogger_DbLoggerCategory_Update__" data-uid="MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaCluster.EnsureConnected(IModel,IDiagnosticsLogger{DbLoggerCategory.Update})">EnsureConnected(IModel, IDiagnosticsLogger&lt;DbLoggerCategory.Update&gt;)</h4>
@@ -483,7 +483,7 @@ <h5 class="returns">Returns</h5>
     <a href="https://github.com/masesgroup/KEFCore/new/master/apiSpec/new?filename=MASES_EntityFrameworkCore_KNet_Storage_Internal_KafkaCluster_EnsureCreated_IUpdateAdapterFactory_IModel_IDiagnosticsLogger_DbLoggerCategory_Update__.md&amp;value=---%0Auid%3A%20MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaCluster.EnsureCreated(IUpdateAdapterFactory%2CIModel%2CIDiagnosticsLogger%7BDbLoggerCategory.Update%7D)%0Asummary%3A%20'*You%20can%20override%20summary%20for%20the%20API%20here%20using%20*MARKDOWN*%20syntax'%0A---%0A%0A*Please%20type%20below%20more%20information%20about%20this%20API%3A*%0A%0A">Improve this Doc</a>
   </span>
   <span class="small pull-right mobile-hide">
-    <a href="https://github.com/masesgroup/KEFCore/blob/master/src/net/KEFCore/Storage/Internal/KafkaCluster.cs/#L138">View Source</a>
+    <a href="https://github.com/masesgroup/KEFCore/blob/master/src/net/KEFCore/Storage/Internal/KafkaCluster.cs/#L148">View Source</a>
   </span>
   <a id="MASES_EntityFrameworkCore_KNet_Storage_Internal_KafkaCluster_EnsureCreated_" data-uid="MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaCluster.EnsureCreated*"></a>
   <h4 id="MASES_EntityFrameworkCore_KNet_Storage_Internal_KafkaCluster_EnsureCreated_IUpdateAdapterFactory_IModel_IDiagnosticsLogger_DbLoggerCategory_Update__" data-uid="MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaCluster.EnsureCreated(IUpdateAdapterFactory,IModel,IDiagnosticsLogger{DbLoggerCategory.Update})">EnsureCreated(IUpdateAdapterFactory, IModel, IDiagnosticsLogger&lt;DbLoggerCategory.Update&gt;)</h4>
@@ -597,7 +597,7 @@ <h5 class="returns">Returns</h5>
     <a href="https://github.com/masesgroup/KEFCore/new/master/apiSpec/new?filename=MASES_EntityFrameworkCore_KNet_Storage_Internal_KafkaCluster_ExecuteTransaction_System_Collections_Generic_IList_IUpdateEntry__IDiagnosticsLogger_DbLoggerCategory_Update__.md&amp;value=---%0Auid%3A%20MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaCluster.ExecuteTransaction(System.Collections.Generic.IList%7BIUpdateEntry%7D%2CIDiagnosticsLogger%7BDbLoggerCategory.Update%7D)%0Asummary%3A%20'*You%20can%20override%20summary%20for%20the%20API%20here%20using%20*MARKDOWN*%20syntax'%0A---%0A%0A*Please%20type%20below%20more%20information%20about%20this%20API%3A*%0A%0A">Improve this Doc</a>
   </span>
   <span class="small pull-right mobile-hide">
-    <a href="https://github.com/masesgroup/KEFCore/blob/master/src/net/KEFCore/Storage/Internal/KafkaCluster.cs/#L276">View Source</a>
+    <a href="https://github.com/masesgroup/KEFCore/blob/master/src/net/KEFCore/Storage/Internal/KafkaCluster.cs/#L286">View Source</a>
   </span>
   <a id="MASES_EntityFrameworkCore_KNet_Storage_Internal_KafkaCluster_ExecuteTransaction_" data-uid="MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaCluster.ExecuteTransaction*"></a>
   <h4 id="MASES_EntityFrameworkCore_KNet_Storage_Internal_KafkaCluster_ExecuteTransaction_System_Collections_Generic_IList_IUpdateEntry__IDiagnosticsLogger_DbLoggerCategory_Update__" data-uid="MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaCluster.ExecuteTransaction(System.Collections.Generic.IList{IUpdateEntry},IDiagnosticsLogger{DbLoggerCategory.Update})">ExecuteTransaction(IList&lt;IUpdateEntry&gt;, IDiagnosticsLogger&lt;DbLoggerCategory.Update&gt;)</h4>
@@ -649,7 +649,7 @@ <h5 class="returns">Returns</h5>
     <a href="https://github.com/masesgroup/KEFCore/new/master/apiSpec/new?filename=MASES_EntityFrameworkCore_KNet_Storage_Internal_KafkaCluster_GetData_IEntityType_.md&amp;value=---%0Auid%3A%20MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaCluster.GetData(IEntityType)%0Asummary%3A%20'*You%20can%20override%20summary%20for%20the%20API%20here%20using%20*MARKDOWN*%20syntax'%0A---%0A%0A*Please%20type%20below%20more%20information%20about%20this%20API%3A*%0A%0A">Improve this Doc</a>
   </span>
   <span class="small pull-right mobile-hide">
-    <a href="https://github.com/masesgroup/KEFCore/blob/master/src/net/KEFCore/Storage/Internal/KafkaCluster.cs/#L252">View Source</a>
+    <a href="https://github.com/masesgroup/KEFCore/blob/master/src/net/KEFCore/Storage/Internal/KafkaCluster.cs/#L262">View Source</a>
   </span>
   <a id="MASES_EntityFrameworkCore_KNet_Storage_Internal_KafkaCluster_GetData_" data-uid="MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaCluster.GetData*"></a>
   <h4 id="MASES_EntityFrameworkCore_KNet_Storage_Internal_KafkaCluster_GetData_IEntityType_" data-uid="MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaCluster.GetData(IEntityType)">GetData(IEntityType)</h4>
diff --git a/docs/manifest.json b/docs/manifest.json
index 923bd2f7..e17f90b7 100644
--- a/docs/manifest.json
+++ b/docs/manifest.json
@@ -669,7 +669,7 @@
       "output": {
         ".html": {
           "relative_path": "api/MASES.EntityFrameworkCore.KNet.Storage.Internal.KafkaCluster.html",
-          "hash": "iJXUrirWPYLkDSDJuZX2OzZEFPPwE1bg/jlesHMOBFU="
+          "hash": "w9cmcCHcd9/fq6ToerQPk/TPEtkCRFJKQORpscUHkYE="
         }
       },
       "is_incremental": false,