[Bug] Non-persistent failover topics are not notified on active consumer changes

[smbecker]

Search before asking

• I searched in the issues and found nothing similar.

Read release policy

• I understand that unsupported versions don't get bug fixes. I will attempt to reproduce the issue on a supported version of Pulsar client and Pulsar broker.

Version

4.0

Minimal reproduce step

• Create a non-persistent topic with a consumer and failover subscription
• Notice that the consumer is never notified whether it is the active consumer or not

I wrote a minimal test demonstrating that persistent and non-persistent consumers are treated differently.

What did you expect to see?

I would expect consumers on non-persistent failover topics to be notified of active consumer changes similar to how they are notified in persistent topics.

What did you see instead?

Consumers on non-persistent failover topics are not notified of active consumer changes.

Anything else?

In looking at PersistentDispatcherSingleActiveConsumer.java, you can see that there is a call to notify consumers of the change. However, in NonPersistentDispatcherSingleActiveConsumer.java, no attempt is made to notify consumers of the change. Is this by design? I would expect the behaviors to be consistent.

Are you willing to submit a PR?

• I'm willing to submit a PR!