@Override
        public Executor getExecutor() {
            return null;
        }
Initializes the TubeMQ consumer client(s) with the specified requirements.
inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/tools/cli/CliConsumer.java