pulsar-client-go
pulsar-client-go copied to clipboard
ManagedConsumer.Close() not work finally
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()?