Pavel

pulsar-client-go version 0.8.1 consumer type is shared, one topic (but topic has partitions)

Hello, I've also interested in this issue. Currently it is impossible to detect if consumer closed if you are not using `consumer.Receive()` method. But this method is blocking and is...

Added pull request with fix

Yes, but in the case it stops reconnecting consumer will just stuck and no notification would be passed to the caller. In the pr I've added closing consumer in this...

@wolfstudy Hi! Sorry for direct mention, but could we proceed with this issue in any way?

Added fix to prevent possible panic when pulsar returns error in consumer initialization step

@wolfstudy Hi, could you please review this PR?

@wolfstudy Could you please release this fix within the 0.9.0 release?

@wolfstudy Sorry for annoying you, but is it possible to include this PR into next release?

@wolfstudy Hi! Any changes should be made to accept this pr?