pulsar-client-go
pulsar-client-go copied to clipboard
ManagedConsumer: after Close(), will reconnect to pulsar
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()?