Реестру схемы Kafka не удалось подключиться к Kafka Broker (Testcontainers) ⇐ JAVA

[Anonymous]

Мне нужно написать интеграционный тест для совместной работы Kafka и Schema Registry из-за использования сериализации AVRO.
Мой Maven настроен следующим образом (Apple M2 Max)

Код: Выделить всё

% mvn -version
Apache Maven 3.9.9 (8e8579a9e76f7d015ee5ec7bfcdc97d260186937)
Maven home: /opt/homebrew/Cellar/maven/3.9.9/libexec
Java version: 17.0.13, vendor: Amazon.com Inc., runtime: /Users/neo.bsuir/.sdkman/candidates/java/17.0.13-amzn
Default locale: en_US, platform encoding: UTF-8
OS name: "mac os x", version: "15.1.1", arch: "aarch64", family: "mac"

Мой тест выглядит так:

Код: Выделить всё

@SpringBootTest
@Testcontainers
public class KafkaIntegrationTest {

public static final String CONFLUENT_PLATFORM_VERSION = "7.5.1";

private static final ConfluentKafkaContainer KAFKA_CONTAINER;
private static final GenericContainer SCHEMA_REGISTER_CONTAINER;

static {

final Network network = Network.newNetwork();

KAFKA_CONTAINER =
new ConfluentKafkaContainer(
DockerImageName.parse("confluentinc/cp-kafka:" + CONFLUENT_PLATFORM_VERSION))
.withNetwork(network)
.withNetworkAliases("kafka")
.withEnv("KAFKA_BROKER_ID", "1")
.withEnv("KAFKA_LISTENERS", "PLAINTEXT://0.0.0.0:9092,BROKER://0.0.0.0:9093,CONTROLLER://0.0.0.0:9094")
.withEnv("KAFKA_ADVERTISED_LISTENERS", "PLAINTEXT://kafka:9092,BROKER://kafka:9093,CONTROLLER://kafka:9094")
.withEnv("KAFKA_LISTENER_SECURITY_PROTOCOL_MAP", "PLAINTEXT:PLAINTEXT,BROKER:PLAINTEXT,CONTROLLER:PLAINTEXT")
.withEnv("KAFKA_INTER_BROKER_LISTENER_NAME", "BROKER")
.withEnv("KAFKA_CONTROLLER_LISTENER_NAMES", "CONTROLLER")
.withEnv("KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR", "1")
.withEnv("KAFKA_TRANSACTION_STATE_LOG_REPLICATION_FACTOR", "1")
.withExposedPorts(9092, 9093, 9094)
.waitingFor(Wait.forListeningPorts(9092));
KAFKA_CONTAINER.start();

SCHEMA_REGISTER_CONTAINER = new GenericContainer(
DockerImageName.parse("confluentinc/cp-schema-registry:" + CONFLUENT_PLATFORM_VERSION))
.withNetwork(network)
.withExposedPorts(8081)
.withEnv("SCHEMA_REGISTRY_HOST_NAME", "schema-registry")
.withEnv("SCHEMA_REGISTRY_LISTENERS", "http://0.0.0.0:8081")
.withEnv("SCHEMA_REGISTRY_KAFKASTORE_BOOTSTRAP_SERVERS",KAFKA_CONTAINER.getBootstrapServers())
.dependsOn(KAFKA_CONTAINER)
.waitingFor(Wait.forHttp("/subjects").forStatusCode(200)
.withStartupTimeout(Duration.ofSeconds(5)));
SCHEMA_REGISTER_CONTAINER.start();
}

@Test
void shouldHaveHealthyContainers() {
assertThat(KAFKA_CONTAINER.isHealthy()).isTrue();
assertThat(SCHEMA_REGISTER_CONTAINER.isHealthy()).isTrue();
}

@AfterAll
static void afterAll() {
if (SCHEMA_REGISTER_CONTAINER != null) {
SCHEMA_REGISTER_CONTAINER.stop();
}
if (KAFKA_CONTAINER != null) {
KAFKA_CONTAINER.stop();
}
}
}

Я передал getBootstrapServers() в SCHEMA_REGISTER_CONTAINER, но тест не прошёл из-за того, что Соединение с узлом -1 (localhost/127.0.0.1:54380) могло не устанавливаться. Брокер может быть недоступен.
Полный вывод из target/surefire-reports/com.example.testcontainers.KafkaIntegrationTest.txt:

Код: Выделить всё

-------------------------------------------------------------------------------
Test set: com.example.testcontainers.KafkaIntegrationTest
-------------------------------------------------------------------------------
Tests run: 2, Failures: 0, Errors: 2, Skipped: 0, Time elapsed: 9.166 s 

Подробнее здесь: [url]https://stackoverflow.com/questions/79322178/kafka-schema-registry-failed-to-connect-to-kafka-broker-testcontainers[/url]