Невозможно подключиться к реестру схемы Kafka, созданному с помощью TestContainers в тестовых примерах. ⇐ C#

[Anonymous]

Я пытаюсь добавить службу Kafka в свои тестовые примеры SpecFlow, где я создал тестовые контейнеры Kafka и SchemaRegistry. Теперь, когда я запускаю тесты в режиме отладки, мой код подключается к реестру схемы и службе Kafka, и мой тестовый пример проходит. Но запустить выпускную сборку набора тестов не удается. Выдает следующую ошибку.
{
"Timestamp": "2025-01-16T12:15:50.2390813+05:30",
"Level": "Error",
"MessageTemplate": "Message delivery failed for Key: {Key}, Reason: {Reason}",
"Exception": "Confluent.Kafka.ProduceException`2[System.String,Products.Models.Options.ProductPrintDesignLibrary]: Local: Value serialization error\r\n ---> System.Net.Http.HttpRequestException: [http://localhost:8082/] HttpRequestException: An error occurred while sending the request.\r\n at Confluent.SchemaRegistry.RestService.ExecuteOnOneInstanceAsync(Func`1 createRequest)\r\n at Confluent.SchemaRegistry.RestService.RequestAsync[T](String endPoint, HttpMethod method, Object[] jsonBody)\r\n at Confluent.SchemaRegistry.RestService.RegisterSchemaAsync(String subject, Schema schema, Boolean normalize)"
}

Вот фрагменты моего кода.
Конфигурация Kafka
private static readonly INetwork Network = new NetworkBuilder().Build();

private readonly KafkaContainer _kafkaContainer = new KafkaBuilder()
.WithNetwork(Network)
.WithNetworkAliases("kafka")
.WithEnvironment("KAFKA_LISTENERS", "PLAINTEXT://0.0.0.0:9092,BROKER://0.0.0.0:9093")
.WithEnvironment("KAFKA_ADVERTISED_LISTENERS", "PLAINTEXT://kafka:9092,BROKER://kafka:9093")
.WithEnvironment("KAFKA_LISTENER_SECURITY_PROTOCOL_MAP", "PLAINTEXT:PLAINTEXT,BROKER:PLAINTEXT")
.WithEnvironment("KAFKA_INTER_BROKER_LISTENER_NAME", "BROKER")
.WithExposedPort(9092)
.WithExposedPort(9093)
.WithWaitStrategy(Wait.ForUnixContainer().UntilPortIsAvailable(9093))
.Build();

Реестр схемы
private void ConfigureKafkaSchemaRegistry()
{
_schemaRegistryContainer = new ContainerBuilder()
.WithNetwork(Network)
.WithImage("confluentinc/cp-schema-registry:latest")
.WithEnvironment("SCHEMA_REGISTRY_KAFKASTORE_BOOTSTRAP_SERVERS", "kafka:9093")
.WithEnvironment("SCHEMA_REGISTRY_HOST_NAME", "schema-registry")
.WithEnvironment("SCHEMA_REGISTRY_LISTENERS", $"http://0.0.0.0:{SchemaRegistryPort}")
.WithPortBinding(SchemaRegistryPort, SchemaRegistryPort)
.WithExposedPort(SchemaRegistryPort)
.Build();
}

Код производителя Kafka
var schemaRegistryConfig = new SchemaRegistryConfig
{
Url = _eventConfig.SchemaUrl,
BasicAuthCredentialsSource = AuthCredentialsSource.UserInfo,
BasicAuthUserInfo = $"{_eventConfig.SchemaApiKey}:{_eventConfig.SchemaApiSecret}"
};

using var schemaRegistry = new CachedSchemaRegistryClient(schemaRegistryConfig);
using var producer = new ProducerBuilder(producerConfig)
.SetValueSerializer(new JsonSerializer(schemaRegistry))
.Build();

var dr = await producer.ProduceAsync(topicName, message);


Подробнее здесь: https://stackoverflow.com/questions/793 ... -in-testca