pulsar-client-go icon indicating copy to clipboard operation
pulsar-client-go copied to clipboard

ManagedConsumer: after Close(), will reconnect to pulsar

Open JaydenHan1106 opened this issue 5 years ago • 0 comments

after ManagedConsumer.Close(), ManagedConsumer.manage() will receive <-consumer.Closed(), but would reconnect, as a result close not work finally. so why reconnect when receive <-consumer.Closed()?

JaydenHan1106 avatar Jun 28 '19 06:06 JaydenHan1106