public DataCarrier consume(Class<? extends IConsumer<T>> consumerClass, int num) {
        return this.consume(consumerClass, num, 200, new Properties());
    }
set consumeDriver to this Carrier. consumer begins to run when {@link DataCarrier#produce} begin to work with 200
millis consume cycle.

@param consumerClass class of consumer
@param num           number of consumer threads
oap-server/server-library/library-datacarrier-queue/src/main/java/org/apache/skywalking/oap/server/library/datacarrier/DataCarrier.java