Closed hanzai closed 4 years ago
如果refreshMeta和heartbeat同时触发了restart。第二次restart开始的时候,会调用stop(),将simple_consumer.stop置为true。而此时第一次restart启动的simple_consumer.Consume可能还没运行到c.stop=false,c.stop还会被置为false,导致simple_consumer无法停止,restart操作pending
如果refreshMeta和heartbeat同时触发了restart。第二次restart开始的时候,会调用stop(),将simple_consumer.stop置为true。而此时第一次restart启动的simple_consumer.Consume可能还没运行到c.stop=false,c.stop还会被置为false,导致simple_consumer无法停止,restart操作pending