Fix race condition/goroutine leak in partition discovery goroutine#474

Merged

merlimat merged 3 commits intoapache:masterfrom PowerStateFailure:fix-partition-discovery-leak

Mar 30, 2021

+66-40

Commits on Mar 29, 2021

pulsar/consumer_impl: rewrite partition discovery goroutine so that it actually gets closed before close active consumers
PowerStateFailure
committed
pulsar/producer_impl: rewrite partition discovery goroutine so that it actually gets closed before close active producers
PowerStateFailure
committed
pulsar/producer_impl: avoid consequtive Close calls side-effects by wrapping method body with sync.Once (similar to consumer.Close)
PowerStateFailure
committed