3 references to KafkaPort
Aspire.Confluent.Kafka.Tests (3)
KafkaContainerFixture.cs (3)
50
.WithPortBinding(
KafkaPort
, true)
51
.WithEnvironment("KAFKA_LISTENERS", $"PLAINTEXT://localhost:29092,CONTROLLER://localhost:29093,PLAINTEXT_HOST://0.0.0.0:{
KafkaPort
}")
62
startupScript.Append($"export KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://localhost:29092,PLAINTEXT_HOST://localhost:{container.GetMappedPublicPort(
KafkaPort
)}");