fix loop

yuz10 · Nov 7, 2024 · 2f7f323 · 2f7f323
1 parent efad02d
commit 2f7f323
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/resty/rocketmq/consumer/rebalancer.lua b/lib/resty/rocketmq/consumer/rebalancer.lua
@@ -236,7 +236,7 @@ function _M:start()
     local self = self
     local loop
     loop = function()
-        if self.exit then
+        if not self.consumer.running then
             return
         end
         doRebalance(self)