@Testcontainers  // <- ajouter extention
class ExampleTestWithElasticsearch {

    @Container  // <- déclarer un ou plusieurs containeurs
    ElasticsearchContainer container =
            new ElasticsearchContainer("docker.elastic.co/elasticsearch/elasticsearch:6.5.4");

    @Test
    public void exampleTest() {
        container.getHttpHostAddress();  // <- récuperer le port exposé et s'y connecter
        //...
    }
}

@Testcontainers
class ExampleTestWithElasticsearch {

    @Container  // <- containeur partagé
    static ElasticsearchContainer container =
            new ElasticsearchContainer("docker.elastic.co/elasticsearch/elasticsearch:6.5.4");

    RestHighLevelClient client;

    @BeforeEach
    public void init() {
        /* We get Elasticsearch host-port */
        String httpHostAddress = container.getHttpHostAddress();

        RestClientBuilder clientBuilder = RestClient.builder(HttpHost.create(httpHostAddress));
        client = new RestHighLevelClient(clientBuilder);
    }

    @Test
    public void exampleTest1() { /* ... */ }

    @Test
    public void exampleTest2() { /* ... */ }
}

/* Attention! Don't add annotation @Testcontainers nor @Container */
abstract class AbstractElasticsearchTest {
    static ElasticsearchContainer container =
            new ElasticsearchContainer("docker.elastic.co/elasticsearch/elasticsearch:6.5.4");
    static {
        container.start();
    }
}

class ExampleTestWithElasticsearch extends AbstractElasticsearchTest {
    RestHighLevelClient client;

    @BeforeEach
    public void init() {
        /* We get Elasticsearch host-port */
        String httpHostAddress = container.getHttpHostAddress();

        RestClientBuilder clientBuilder = RestClient.builder(HttpHost.create(httpHostAddress));
        client = new RestHighLevelClient(clientBuilder);
    }

    @Test
    public void exampleTest() { /* ... */ }
}

ElasticsearchContainer container =
        new ElasticsearchContainer("docker.elastic.co/elasticsearch/elasticsearch:6.5.4");

container.start();
//...
container.stop();

ou

try (ElasticsearchContainer container =
             new ElasticsearchContainer("docker.elastic.co/elasticsearch/elasticsearch:6.5.4")) {
    container.start();
    // Stop is called by try-with-resources
}

ElasticsearchContainer container =
        new ElasticsearchContainer("docker.elastic.co/elasticsearch/elasticsearch:6.5.4");
        

KafkaContainer kafkaContainer = new KafkaContainer();
kafkaContainer.start();

/* Get Kafka bootstrap servers for client */
kafkaContainer.getBootstrapServers();

ou avec Zookeeper externe

KafkaContainer kafkaContainer = new KafkaContainer().withExternalZookeeper("localhost:2181");

@Container
GenericContainer redis = new GenericContainer<>("redis:5.0.3-alpine")
        .withExposedPorts(6379);
        

# application.yml
spring:
  data:
    elasticsearch:
      cluster-name: my-cluster
      cluster-nodes: localhost:9200
      

@SpringBootTest
@Testcontainers
public class CatalogTaskletIntegrationTest {

    @Container
    static ElasticsearchContainer elasticsearch = 
        new ElasticsearchContainer("docker.elastic.co/elasticsearch/elasticsearch:6.5.4")
            .withEnv("cluster.name", "my-cluster");

    @DynamicPropertySource
    static void elasticsearchProperties(DynamicPropertyRegistry registry) {
        registry.add("spring.data.elasticsearch.cluster-name", () -> "my-cluster");
        registry.add("spring.data.elasticsearch.cluster-nodes", elasticsearch::getHttpHostAddress);
    }
}