ConsumerApplicationTests.java

public class ConsumerApplicationTests {

    public static void main(String[] args) {
        SpringApplication.from(ConsumerApplication::main)
                .with(ContainerConfiguration.class)
                .run(args);
    }

    @TestConfiguration
    static class ContainerConfiguration {

        @Bean
        @RestartScope
        PulsarContainer pulsarContainer(DynamicPropertyRegistry registry) {
            PulsarContainer pulsar = new PulsarContainer(DockerImageName.parse("apachepulsar/pulsar:2.11.0"))
                    .withReuse(true);
            registry.add("spring.pulsar.client.service-url", pulsar::getPulsarBrokerUrl);
            return pulsar;
        }

    }

}