Как запустить тестовый контейнер kafka перед инициализаторами @ContextConfiguration?

Я хотел бы запустить тестовый контейнер kafka и получить его загрузочные серверы:

@SpringBootTest
@ContextConfiguration(classes = {TestConfig.class, MyApplication.class}, initializers = MyIntegrationTest.Initializer.class)
@Testcontainers
public class MyIntegrationTest {

    @Container
    private static final KafkaContainer KAFKA = new KafkaContainer();

static class Initializer implements ApplicationContextInitializer<ConfigurableApplicationContext> {

    @Override
    public void initialize(@NotNull ConfigurableApplicationContext configurableApplicationContext) {
        TestPropertyValues values = TestPropertyValues.of(
            "spring.kafka.consumer.bootstrap-servers=" + KAFKA.getBootstrapServers(),
            "spring.producer.bootstrap-servers=" + KAFKA.getBootstrapServers()
        );
        values.applyTo(configurableApplicationContext);
    }
}

К сожалению, я получаю:

java.lang.IllegalStateException: You should start Kafka container first
at org.testcontainers.containers.KafkaContainer.getBootstrapServers(KafkaContainer.java:65) ~[kafka-1.12.2.jar:na]

java apache-kafka testcontainers junit5 spring-boot-test
person pixel    schedule 22.10.2019    source источник

Ответы (1)


arrow_upward
3
arrow_downward

Единственная проблема заключается в том, что для вызова метода start() после вызова объекта

private static void startKafkaContainer() {

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

    }

Дополнительную информацию см. в этом репозиторий, пожалуйста.

person Hatice    schedule 22.10.2019