[Bug] pulsar-io EventLoopGroup is used in dispatchers to execute synchronized code and CPU intensive work

[lhotari]

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

All released versions

Minimal reproduce step

In dispatchers, topic.getBrokerService().executor(), the "pulsar-io" EventLoopGroup is used to execute synchronized code and CPU intensive work. The "pulsar-io" EventLoopGroup is intended to be the worker for Pulsar's ServerCnx Netty handler so that network connections remain responsive. Since dispatcher implementations contain multiple synchronized methods, blocking operations could impact all connections that are bound to the same IO thread.

Another potential problem that the solution causes unnecessary context switching since the current solution doesn't use a single thread for the scheduled jobs and the work that it performs.

What did you expect to see?

A pinned executor to be used for executing all operations for a dispatcher or replicator.

What did you see instead?

EventLoopGroup is used as executor and the thread could change for each execution.

Anything else?

No response

Are you willing to submit a PR?

• I'm willing to submit a PR!