tests(WIP): eventhubs kafka usage example

Author: rafek1241

docs/modules/eventhubs.md

@@ -33,3 +33,13 @@ This example uses xUnit.net's `IAsyncLifetime` interface to manage the lifecycle
 ```csharp
 --8<-- "tests/Testcontainers.EventHubs.Tests/EventHubsContainerTest.cs:EventHubsUsage"
 ```
+
+=== "Kafka support"
+
+Azure Event Hubs is compatible with Apache Kafka. You can use the Azure Event Hubs Kafka endpoint to connect to the Event Hubs instance.
+The following example demonstrates how to use the Azure Event Hubs Kafka endpoint with the Testcontainers library. Please,
+keep in mind that only consumer and producer API is supported. More information about known limitations can be found [here](https://learn.microsoft.com/en-us/azure/event-hubs/overview-emulator#known-limitations).
+
+```csharp
+--8<-- "tests/Testcontainers.EventHubs.Tests/EventHubsContainerTest.cs:EventHubsKafkaUsage"
+```

tests/Testcontainers.EventHubs.Tests/EventHubsContainerTest.cs

@@ -55,6 +55,59 @@ await client.SendAsync(eventDataBatch)
         Assert.NotNull(properties);
     }
     // # --8<-- [end:EventHubsUsage]
+    
+    // # --8<-- [start:EventHubsKafkaUsage]
+    
+    [Fact]
+    [Trait(nameof(DockerCli.DockerPlatform), nameof(DockerCli.DockerPlatform.Linux))]
+    public async Task UsingKafkaShouldNotThrowException()
+    {
+        // Given
+        var kafkaPort = _eventHubsContainer.GetMappedPublicPort(EventHubsBuilder.KafkaPort);
+        var bootstrapServer = $"localhost:{kafkaPort}";
+        var connectionString = _eventHubsContainer.GetConnectionString();
+
+        var producerConfig = new ProducerConfig
+        {
+            BootstrapServers = bootstrapServer,
+            SecurityProtocol = SecurityProtocol.SaslPlaintext,
+            SaslMechanism = SaslMechanism.Plain,
+            SaslUsername = "$ConnectionString",
+            SaslPassword = connectionString
+        };
+
+        var consumerConfig = new ConsumerConfig
+        {
+            BootstrapServers = bootstrapServer,
+            SecurityProtocol = SecurityProtocol.SaslPlaintext,
+            SaslMechanism = SaslMechanism.Plain,
+            SaslUsername = "$ConnectionString",
+            SaslPassword = connectionString,
+            GroupId = EventHubsConsumerGroupName,
+            AutoOffsetReset = AutoOffsetReset.Earliest,
+        };
+
+        var message = new Message<string, string>
+        {
+            Value = Guid.NewGuid().ToString("D"),
+        };
+
+        // When
+        using var producer = new ProducerBuilder<string, string>(producerConfig).Build();
+        _ = await producer.ProduceAsync(EventHubsName, message)
+            .ConfigureAwait(true);
+
+        using var consumer = new ConsumerBuilder<string, string>(consumerConfig).Build();
+        consumer.Subscribe(EventHubsName);
+
+        var result = consumer.Consume(TimeSpan.FromSeconds(15));
+
+        // Then
+        Assert.NotNull(result);
+        Assert.Equal(message.Value, result.Message.Value);
+    }
+    
+    // # --8<-- [end:EventHubsKafkaUsage]
 
     // # --8<-- [start:MinimalConfigurationEventHubs]
     [UsedImplicitly]

tests/Testcontainers.EventHubs.Tests/Testcontainers.EventHubs.Tests.csproj

@@ -10,6 +10,7 @@
         <PackageReference Include="xunit.runner.visualstudio"/>
         <PackageReference Include="xunit"/>
         <PackageReference Include="Azure.Messaging.EventHubs"/>
+        <PackageReference Include="Confluent.Kafka"/>
     </ItemGroup>
     <ItemGroup>
         <ProjectReference Include="../../src/Testcontainers.EventHubs/Testcontainers.EventHubs.csproj"/>

tests/Testcontainers.EventHubs.Tests/Usings.cs

@@ -1,8 +1,8 @@
 global using System;
-global using System.Text;
 global using System.Threading.Tasks;
 global using Azure.Messaging.EventHubs;
 global using Azure.Messaging.EventHubs.Producer;
+global using Confluent.Kafka;
 global using DotNet.Testcontainers.Builders;
 global using DotNet.Testcontainers.Commons;
 global using DotNet.Testcontainers.Networks;