[Feature Request]: Consumer Async Using LibrdKafka poll(Timespan span) method

[YaliBar]

Is your request related to a problem you have?

The consumer thread runs on a tenanted k8s node, and the consuming is done using a blocking librdkafka API.
We don't have horizontal scaler, 1 blocked polling Thread for 1 topic consumer model, is a bottleneck for every system.

Describe the solution you'd like

Replace implementation to Async polling, instead of CancelToken and the Sync librdkafka poll

Are you able to help bring it to life and contribute with a Pull Request?

Yes

Additional context

No response