public static ConsumerCreationStrategyFactory create(PulsarConsumer pulsarConsumer) {
        validate(pulsarConsumer);
        return new ConsumerCreationStrategyFactory(pulsarConsumer);
    }
@Test
    public void givenPulsarConsumerAndRetryPolicyNonNullwhenICreateFactoryverifyIllegalArgumentExceptionIsNotThrown() {
        ConsumerCreationStrategyFactory factory = ConsumerCreationStrategyFactory.create(mock(PulsarConsumer.class));

        assertNotNull(factory);
    }