public static void pauseConsumers(final Queue<Consumer<byte[]>> consumers) {
        consumers.forEach(Consumer::pause);
    }
@Test
    public void pauseConsumers() {
        Consumer<byte[]> consumer = mock(Consumer.class);

        Queue<Consumer<byte[]>> consumers = new ConcurrentLinkedQueue<>();
        consumers.add(consumer);

        PulsarUtils.pauseConsumers(consumers);

        verify(consumer).pause();
    }