public void shutdownConsumers() {
        if (driver != null) {
            driver.close(channels);
        }
    }
shutdown all consumer threads, if consumer threads are running. Notice {@link BufferStrategy}: if {@link
BufferStrategy} == {@link BufferStrategy#BLOCKING}, shutdown consumeDriver maybe cause blocking when producing.
Better way to change consumeDriver are use {@link DataCarrier#consume}
oap-server/server-library/library-datacarrier-queue/src/main/java/org/apache/skywalking/oap/server/library/datacarrier/DataCarrier.java