How to use KafkaTestcontainerConfiguration class of DotNet.Testcontainers.Configurations package

Best Testcontainers-dotnet code snippet using DotNet.Testcontainers.Configurations.KafkaTestcontainerConfiguration

KafkaTestcontainerConfiguration.cs

Source:KafkaTestcontainerConfiguration.cs

...9  using DotNet.Testcontainers.Containers;10  using JetBrains.Annotations;11  /// <inheritdoc cref="TestcontainerMessageBrokerConfiguration" />12  [PublicAPI]13  public class KafkaTestcontainerConfiguration : TestcontainerMessageBrokerConfiguration14  {15    private const string KafkaImage = "confluentinc/cp-kafka:6.0.5";16    private const string StartupScriptPath = "/testcontainers_start.sh";17    private const int KafkaPort = 9092;18    private const int BrokerPort = 9093;19    private const int ZookeeperPort = 2181;20    /// <summary>21    /// Initializes a new instance of the <see cref="KafkaTestcontainerConfiguration" /> class.22    /// </summary>23    public KafkaTestcontainerConfiguration()24      : this(KafkaImage)25    {26    }27    /// <summary>28    /// Initializes a new instance of the <see cref="KafkaTestcontainerConfiguration" /> class.29    /// </summary>30    /// <param name="image">The Docker image.</param>31    public KafkaTestcontainerConfiguration(string image)32      : base(image, KafkaPort)33    {34      // Use two listeners with different names, it will force Kafka to communicate with itself via internal35      // listener when KAFKA_INTER_BROKER_LISTENER_NAME is set, otherwise Kafka will try to use the advertised listener.36      this.Environments.Add("KAFKA_LISTENER_SECURITY_PROTOCOL_MAP", "BROKER:PLAINTEXT,PLAINTEXT:PLAINTEXT");37      this.Environments.Add("KAFKA_LISTENERS", $"PLAINTEXT://0.0.0.0:{this.DefaultPort},BROKER://0.0.0.0:{BrokerPort}");38      this.Environments.Add("KAFKA_INTER_BROKER_LISTENER_NAME", "BROKER");39      this.Environments.Add("KAFKA_BROKER_ID", "1");40      this.Environments.Add("KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR", "1");41      this.Environments.Add("KAFKA_OFFSETS_TOPIC_NUM_PARTITIONS", "1");42      this.Environments.Add("KAFKA_LOG_FLUSH_INTERVAL_MESSAGES", long.MaxValue.ToString(CultureInfo.InvariantCulture));43      this.Environments.Add("KAFKA_GROUP_INITIAL_REBALANCE_DELAY_MS", "0");44      this.Environments.Add("KAFKA_ZOOKEEPER_CONNECT", $"localhost:{ZookeeperPort}");45    }...

Program.cs

Source:Program.cs

...37    }38}39// async Task Kafka2(){40//     await Task.Delay(1);41//     KafkaTestcontainerConfiguration configuration = new KafkaTestcontainerConfiguration();42//       var kafkaBuilder1 = new DotNet.Testcontainers.Builders.TestcontainersBuilder<KafkaTestcontainer>();43//       var kafkaBuilder = kafkaBuilder1.WithKafka(configuration);44//     kafkaBuilder.Build();45// }46async Task Kafka()47{48    var kafkaBuilder = new DotNet.Testcontainers.Builders.TestcontainersBuilder<DotNet.Testcontainers.Containers.KafkaTestcontainer>();49    var config = new KafkaTestcontainerConfiguration();50    var kafkaBuilder2 = kafkaBuilder.WithKafka(config);51    await using (var testcontainers = kafkaBuilder2.Build())52    {53        await testcontainers.StartAsync();54        WriteLine($"Started Kafka. Connect with {testcontainers.BootstrapServers}");55        // localhost:4915856        WriteLine("Press enter to end it");57        ReadLine();58    }59}...

KafkaFixture.cs

Source:KafkaFixture.cs

...9  using Xunit;10  [UsedImplicitly]11  public sealed class KafkaFixture : IAsyncLifetime, IDisposable12  {13    private readonly KafkaTestcontainerConfiguration configuration = new KafkaTestcontainerConfiguration();14    public KafkaFixture()15    {16      this.Container = new TestcontainersBuilder<KafkaTestcontainer>()17        .WithKafka(this.configuration)18        .Build();19    }20    public KafkaTestcontainer Container { get; }21    public Task InitializeAsync()22    {23      return this.Container.StartAsync();24    }25    public Task DisposeAsync()26    {27      return this.Container.DisposeAsync().AsTask();...