Dockerized Quarkus Test Resource

ContainerKafkaTestResource.java

public class ContainerKafkaTestResource implements QuarkusTestResourceLifecycleManager {

    private static final KafkaContainer kafka = new KafkaContainer();

    /**
     * @return A map of system properties that should be set for the running tests
     */
    @Override
    public Map<String, String> start() {
        kafka.start();

        Map<String, String> systemProperties = new HashMap<>();
        systemProperties.put("kafka.bootstrap.servers", kafka.getBootstrapServers());
        systemProperties.put("quarkus.kafka-streams.bootstrap-servers", kafka.getBootstrapServers());

        return systemProperties;
    }

    @Override
    public void stop() {
        kafka.close();
    }
}