public static ConsumerCreationStrategyFactory create(PulsarConsumer pulsarConsumer) {
        validate(pulsarConsumer);
        return new ConsumerCreationStrategyFactory(pulsarConsumer);
    }
@Test
    public void givenPulsarConsumerIsNullwhenICreateFactoryverifyIllegalArgumentExceptionIsThrown() {
        assertThrows(IllegalArgumentException.class,
                () -> ConsumerCreationStrategyFactory.create(null));
    }