Why use of Scheduler if the processing has been proven NON blocking please?

[patpatpat123]

Hello,

This is my first ticket in this project.

I would like to start with a big thanks. The talk in Kafka submit was very clear, easy to follow.

I am observing an issue for the reactive parallel consumer please:

https://github.com/confluentinc/parallel-consumer/blob/master/parallel-consumer-reactor/src/main/java/io/confluent/parallelconsumer/reactor/ReactorProcessor.java#L104

May I ask why the publication on the Scheduler please?

Let's suppose the processing of the event is NON blocking, not blocking at all (BlockHound tested non blocking etc...)

Should the Scheduler be removed, if the processing of the event itself has been assured NON blocking, and still be able to have the parallel reactive consumer?

Thank you