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

Best Testcontainers-dotnet code snippet using DotNet.Testcontainers.Configurations.KafkaTestcontainerConfiguration.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();...

KafkaTestcontainerConfiguration

Using AI Code Generation

1using DotNet.Testcontainers.Configurations;2using DotNet.Testcontainers.Containers;3using DotNet.Testcontainers.Containers.Builders;4using DotNet.Testcontainers.Containers.Modules;5using DotNet.Testcontainers.Containers.Modules.Databases;6using DotNet.Testcontainers.Containers.WaitStrategies;7using DotNet.Testcontainers.Images;8using DotNet.Testcontainers.Images.Builders;9using DotNet.Testcontainers.Images.Configurations;10using DotNet.Testcontainers.Tests.Fixtures;11using DotNet.Testcontainers.Tests.Unit;12using Xunit;13{14    {15        public async Task KafkaTestcontainerConfiguration()16        {17            {18            };19            var kafkaTestcontainer = new TestcontainersBuilder<KafkaTestcontainer>()20                .WithConfiguration(kafkaTestcontainerConfiguration)21                .Build();22            await kafkaTestcontainer.StartAsync();23            Assert.Equal("test", kafkaTestcontainer.Configuration.Topic);24            Assert.Equal(1, kafkaTestcontainer.Configuration.Partitions);25            Assert.Equal(1, kafkaTestcontainer.Configuration.ReplicationFactor);26            await kafkaTestcontainer.StopAsync();27        }28    }29}30using DotNet.Testcontainers.Configurations;31using DotNet.Testcontainers.Containers;32using DotNet.Testcontainers.Containers.Builders;33using DotNet.Testcontainers.Containers.Modules;34using DotNet.Testcontainers.Containers.Modules.Databases;35using DotNet.Testcontainers.Containers.WaitStrategies;36using DotNet.Testcontainers.Images;37using DotNet.Testcontainers.Images.Builders;38using DotNet.Testcontainers.Images.Configurations;39using DotNet.Testcontainers.Tests.Fixtures;40using DotNet.Testcontainers.Tests.Unit;41using Xunit;42{43    {44        public async Task KafkaTestcontainerConfiguration()45        {46            {47            };48            var kafkaTestcontainer = new TestcontainersBuilder<KafkaTestcontainer>()49                .WithConfiguration(kafkaTestcontainerConfiguration)

KafkaTestcontainerConfiguration

Using AI Code Generation

1using DotNet.Testcontainers.Configurations;2using DotNet.Testcontainers.Containers;3using DotNet.Testcontainers.Containers.Builders;4using DotNet.Testcontainers.Containers.Modules;5using DotNet.Testcontainers.Containers.Modules.Databases;6using DotNet.Testcontainers.Containers.WaitStrategies;7using System;8using System.Threading.Tasks;9{10  {11    public KafkaTestcontainerConfiguration() : base("confluentinc/cp-kafka", "5.4.3")12    {13      this.Port = 9092;14      this.WaitStrategy = Wait.ForUnixContainer().UntilPortIsAvailable(this.Port);15      this.Environments.Add("KAFKA_ZOOKEEPER_CONNECT", "localhost:2181");16      this.Environments.Add("KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR", "1");17    }18  }19}20using DotNet.Testcontainers.Configurations;21using DotNet.Testcontainers.Containers;22using DotNet.Testcontainers.Containers.Builders;23using DotNet.Testcontainers.Containers.Modules;24using DotNet.Testcontainers.Containers.Modules.Databases;25using DotNet.Testcontainers.Containers.WaitStrategies;26using System;27using System.Threading.Tasks;28{29  {30    public KafkaTestcontainerConfiguration() : base("confluentinc/cp-kafka", "5.4.3")31    {32      this.Port = 9092;33      this.WaitStrategy = Wait.ForUnixContainer().UntilPortIsAvailable(this.Port);34      this.Environments.Add("KAFKA_ZOOKEEPER_CONNECT", "localhost:2181");35      this.Environments.Add("KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR", "1");36    }37  }38}

KafkaTestcontainerConfiguration

Using AI Code Generation

1using DotNet.Testcontainers.Configurations;2using DotNet.Testcontainers.Containers;3using DotNet.Testcontainers.Containers.Builders;4using DotNet.Testcontainers.Containers.Modules;5using DotNet.Testcontainers.Containers.Modules.Databases;6using DotNet.Testcontainers.Containers.WaitStrategies;7using DotNet.Testcontainers.Images;8using DotNet.Testcontainers.Images.Builders;9using System;10using System.Collections.Generic;11using System.Text;12using System.Threading.Tasks;13{14    {15        static async Task Main(string[] args)16        {17            var kafka = new TestcontainersBuilder<KafkaTestcontainer>()18                .WithImage("confluentinc/cp-kafka:5.4.1")19                .WithKafkaTestcontainerConfiguration(new KafkaTestcontainerConfiguration20                {21                })22                .WithExposedPorts(9092)23                .WithWaitStrategy(Wait.ForUnixContainer().UntilPortIsAvailable(9092))24                .Build();25            await kafka.StartAsync();26            Console.WriteLine($"Kafka broker is listening on port {kafka.GetMappedPublicPort(9092)}");27            await kafka.StopAsync();28        }29    }30}

KafkaTestcontainerConfiguration

Using AI Code Generation

1using DotNet.Testcontainers.Configurations;2using DotNet.Testcontainers.Containers;3using DotNet.Testcontainers.Containers.Builders;4using DotNet.Testcontainers.Containers.Configurations;5using DotNet.Testcontainers.Containers.Modules;6using DotNet.Testcontainers.Containers.WaitStrategies;7using System;8using System.Threading.Tasks;9{10    {11        static async Task Main(string[] args)12        {13            var configuration = new KafkaTestcontainerConfiguration();14            var container = new TestcontainersBuilder<KafkaTestcontainer>()15                .WithConfiguration(configuration)16                .Build();17            await container.StartAsync();18            var connectionString = container.ConnectionString;19        }20    }21}22using DotNet.Testcontainers.Configurations;23using DotNet.Testcontainers.Containers;24using DotNet.Testcontainers.Containers.Builders;25using DotNet.Testcontainers.Containers.Configurations;26using DotNet.Testcontainers.Containers.Modules;27using DotNet.Testcontainers.Containers.WaitStrategies;28using System;29using System.Threading.Tasks;30{31    {32        static async Task Main(string[] args)33        {34            var configuration = new KafkaTestcontainerConfiguration();35            var container = new TestcontainersBuilder<KafkaTestcontainer>()36                .WithConfiguration(configuration)37                .Build();38            await container.StartAsync();39            var connectionString = container.ConnectionString;40        }41    }42}43using DotNet.Testcontainers.Configurations;44using DotNet.Testcontainers.Containers;45using DotNet.Testcontainers.Containers.Builders;46using DotNet.Testcontainers.Containers.Configurations;47using DotNet.Testcontainers.Containers.Modules;48using DotNet.Testcontainers.Containers.WaitStrategies;49using System;50using System.Threading.Tasks;51{52    {53        static async Task Main(string[] args)54        {

KafkaTestcontainerConfiguration

Using AI Code Generation

1using DotNet.Testcontainers.Configurations;2using DotNet.Testcontainers.Containers;3using DotNet.Testcontainers.Containers.Modules;4using DotNet.Testcontainers.Containers.Modules.Databases;5using DotNet.Testcontainers.Containers.WaitStrategies;6using DotNet.Testcontainers.Images;7using DotNet.Testcontainers.Images.Builders;8using DotNet.Testcontainers.Images.Configurations;9using System;10using System.Collections.Generic;11using System.Threading.Tasks;12{13    {14        static async Task Main(string[] args)15        {16            var kafka = new TestcontainersContainerBuilder<KafkaTestcontainerConfiguration>()17                .WithImage("confluentinc/cp-kafka:latest")18                .WithEnvironment("KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR", "1")19                .WithEnvironment("KAFKA_ZOOKEEPER_CONNECT", "zookeeper:2181")20                .WithPortBinding(9092, 9092)21                .WithPortBinding(2181, 2181)22                .WithWaitStrategy(Wait.ForUnixContainer().UntilPortIsAvailable(9092))23                .Build();24            await kafka.StartAsync();25            Console.WriteLine("Kafka container started");

KafkaTestcontainerConfiguration

Using AI Code Generation

1using System;2using System.Threading.Tasks;3using DotNet.Testcontainers.Configurations;4using DotNet.Testcontainers.Containers.Builders;5using DotNet.Testcontainers.Containers.Modules;6using DotNet.Testcontainers.Containers.Modules.Databases;7using DotNet.Testcontainers.Containers.WaitStrategies;8using Confluent.Kafka;9using Confluent.Kafka.Admin;10using System.Threading;11using System.Collections.Generic;12using System.Linq;13{14    {15        static async Task Main(string[] args)16        {17            var kafkaTestcontainerConfiguration = new KafkaTestcontainerConfiguration()18            {19                {20                    { "KAFKA_AUTO_CREATE_TOPICS_ENABLE", "false" },21                    { "KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR", "1" },22                },23                WaitStrategy = Wait.ForUnixContainer().UntilPortIsAvailable(9092),24            };25            using (var kafkaTestcontainer = new TestcontainersBuilder<KafkaTestcontainer>()26                .WithConfiguration(kafkaTestcontainerConfiguration)27                .Build())28            {29                await kafkaTestcontainer.StartAsync();30                {31                };32                using (var adminClient = new AdminClientBuilder(adminClientConfig).Build())33                {34                    var topicMetadata = await adminClient.GetMetadataAsync(kafkaTestcontainerConfiguration.Topic, new CancellationTokenSource(TimeSpan.FromSeconds(30)).Token);35                    if (topicMetadata.Topics.Count != 1 || topicMetadata.Topics[0].Partitions.Count != 1)36                    {37                        throw new Exception("Topic was not created correctly");38                    }39                }40                {41                };42                using (var producer = new ProducerBuilder<Null, string>(producerConfig).Build())43                {44                    var deliveryReport = await producer.ProduceAsync(kafkaTestcontainerConfiguration.Topic, new Message<Null, string> { Value = "test" });45                    if (deliveryReport.Status != PersistenceStatus.Persisted)46                    {47                        throw new Exception("Message was not persisted");48                    }49                }50                {

KafkaTestcontainerConfiguration

Using AI Code Generation

1using DotNet.Testcontainers.Configurations;2using System;3using System.Threading.Tasks;4{5    {6        static async Task Main(string[] args)7        {8            var kafkaTestcontainerConfiguration = new KafkaTestcontainerConfiguration();9            Console.WriteLine("Hello World!");10        }11    }12}13using DotNet.Testcontainers.Configurations;14using System;15using System.Threading.Tasks;16{17    {18        static async Task Main(string[] args)19        {20            var kafkaTestcontainerConfiguration = new KafkaTestcontainerConfiguration();21            Console.WriteLine("Hello World!");22        }23    }24}25using DotNet.Testcontainers.Configurations;26using System;27using System.Threading.Tasks;28{29    {30        static async Task Main(string[] args)31        {32            var kafkaTestcontainerConfiguration = new KafkaTestcontainerConfiguration();33            Console.WriteLine("Hello World!");34        }35    }36}37using DotNet.Testcontainers.Configurations;38using System;39using System.Threading.Tasks;40{41    {42        static async Task Main(string[] args)43        {44            var kafkaTestcontainerConfiguration = new KafkaTestcontainerConfiguration();45            Console.WriteLine("Hello World!");46        }47    }48}49using DotNet.Testcontainers.Configurations;50using System;51using System.Threading.Tasks;52{53    {54        static async Task Main(string[] args)55        {56            var kafkaTestcontainerConfiguration = new KafkaTestcontainerConfiguration();57            Console.WriteLine("Hello World!");58        }59    }60}61using DotNet.Testcontainers.Configurations;62using System;63using System.Threading.Tasks;64{65    {

KafkaTestcontainerConfiguration

Using AI Code Generation

1var configuration = new KafkaTestcontainerConfiguration();2var kafkaTestcontainer = new TestcontainersContainer(3  DockerClientConfiguration.DockerDefault);4await kafkaTestcontainer.StartAsync();5var configuration = new KafkaTestcontainerConfiguration();6var kafkaTestcontainer = new TestcontainersContainer(7  new DockerClientConfiguration(

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.