In real case, I use less than 5 threads (dispatch ...

# coroutines

[sailxjx]

In real case, I use less than 5 threads (dispatch topics into different processes) in the production environment. But each thread may read a huge amount of messages, if the sink process can not consume these messages, that cause a OOM.