Is your feature request related to a problem? Please describe.
My usage scenario is that I want to put different businesses into different queues. Businesses change dynamically. When the program is running, it supports putting different data into different queues, and different queues support different threads. consumption.