fix: prevent Kafka auto-recovery while disconnecting

BEagle1984 · Aug 8, 2023 · a30458a · a30458a
1 parent 238f022
commit a30458a
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 5 deletions.
diff --git a/src/Silverback.Integration.Kafka/Messaging/Broker/Kafka/ConsumeLoopHandler.cs b/src/Silverback.Integration.Kafka/Messaging/Broker/Kafka/ConsumeLoopHandler.cs
@@ -176,7 +176,9 @@ private bool ConsumeOnce(CancellationToken cancellationToken)
             }
             catch (Exception ex)
             {
-                AutoRecoveryIfEnabled(ex);
+                if (_consumer is { IsConnected: true, IsDisconnecting: false })
+                    AutoRecoveryIfEnabled(ex);
+
                 return false;
             }
 

diff --git a/src/Silverback.Integration/Messaging/Broker/Consumer.cs b/src/Silverback.Integration/Messaging/Broker/Consumer.cs
@@ -96,14 +96,14 @@ protected Consumer(
         public bool IsConsuming { get; protected set; }
 
         /// <summary>
-        ///     Gets the <see cref="IServiceProvider" /> to be used to resolve the required services.
+        ///     Gets a value indicating whether the consumer is being disconnected.
         /// </summary>
-        protected IServiceProvider ServiceProvider { get; }
+        public bool IsDisconnecting { get; private set; }
 
         /// <summary>
-        ///     Gets a value indicating whether the consumer is being disconnected.
+        ///     Gets the <see cref="IServiceProvider" /> to be used to resolve the required services.
         /// </summary>
-        protected bool IsDisconnecting { get; private set; }
+        protected IServiceProvider ServiceProvider { get; }
 
         /// <summary>
         ///     Gets a value indicating whether the consumer is being stopped.