From 0efd3e00b95d3142154f6f9109bbee0bda684d04 Mon Sep 17 00:00:00 2001
From: "dmytro.liulchuk" <dmytro.liulchuk@gr8.tech>
Date: Mon, 18 May 2026 19:18:56 +0300
Subject: [PATCH] fix: resolve deadlock on partition revoked when consumer is
 paused (#681)

---
 src/KafkaFlow/Consumers/ConsumerFlowManager.cs | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/src/KafkaFlow/Consumers/ConsumerFlowManager.cs b/src/KafkaFlow/Consumers/ConsumerFlowManager.cs
index a2e1d3a2a..770bd82a5 100644
--- a/src/KafkaFlow/Consumers/ConsumerFlowManager.cs
+++ b/src/KafkaFlow/Consumers/ConsumerFlowManager.cs
@@ -143,7 +143,6 @@ private void StartHeartbeat()
     private void StopHeartbeat()
     {
         _heartbeatTokenSource?.Cancel();
-        _heartbeatTask?.GetAwaiter().GetResult();
-        _heartbeatTask?.Dispose();
+        _heartbeatTask = null;
     }
 }