[Enhancement][Consumer] Parallel Execution of Interceptors in beforeConsume Method

[ZhaoGuorui666]

Search before asking

• I searched in the issues and found nothing similar.

Motivation

Currently, the beforeConsume method in ConsumerInterceptors.java executes each interceptor sequentially. Since the interceptors operate independently without dependencies on one another, introducing parallel execution can potentially improve performance.

Solution

No response

Alternatives

No response

Anything else?

No response

Are you willing to submit a PR?

• I'm willing to submit a PR!

[visxu]

Good suggestion. However I have another word, sometimes you need multiple interceptors are executed in extremely order.
Maybe you can add a new boolean parameter requireOrder flag to determine whether to execute interceptors in order or parallel.

[TheMarvelFan]

@visxu @ZhaoGuorui666

I would like to work on this issue if no one already is.

Thanks!

[visxu]

@visxu @ZhaoGuorui666

I would like to work on this issue if no one already is.

Thanks!

Hi, @TheMarvelFan. Thanks for your attention on the issue, while I'm working on it. If you wanna start to contribute to Pulsar, Flaky-Test is a good beginning.
https://github.com/apache/pulsar/issues?q=is%3Aopen+flaky+sort%3Aupdated-desc