public DataCarrier consume(IConsumer<T> consumer, int num, long consumeCycle) {
        if (driver != null) {
            driver.close(channels);
        }
        driver = new ConsumeDriver<T>(this.name, this.channels, consumer, num, consumeCycle);
        driver.begin(channels);
        return this;
    }
set consumeDriver to this Carrier. consumer begin to run when {@link DataCarrier#produce} begin to work.

@param consumer single instance of consumer, all consumer threads will all use this instance.
@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