feat: Add Apache Pulsar module

src/Testcontainers.Pulsar/PulsarBuilder.cs

@@ -163,7 +163,7 @@ private async Task<bool> UntilAsync(PulsarContainer container)
             {
                 try
                 {
-                    _authToken = await container.CreateAuthenticationTokenAsync(TimeSpan.FromDays(365))
+                    _authToken = await container.CreateAuthenticationTokenAsync(TimeSpan.FromHours(1))
                         .ConfigureAwait(false);
 
                     _ = _httpWaitStrategy.WithHeader("Authorization", "Bearer " + _authToken.Trim());

src/Testcontainers.Pulsar/PulsarContainer.cs

@@ -58,9 +58,14 @@ public async Task<string> CreateAuthenticationTokenAsync(TimeSpan expire = defau
             "--subject",
             PulsarBuilder.Username,
             "--expiry-time",
-            $"{expire.TotalSeconds}s",
+            "",
         };
 
+        if (_configuration.Image.FullName is "apachepulsar/pulsar:3.2.0" or "apachepulsar/pulsar:3.2.1" or "apachepulsar/pulsar:3.2.2" or "apachepulsar/pulsar:3.2.3")
+            command[8] = $"{expire.TotalSeconds * 1000}s";
+        else
+            command[8] = $"{expire.TotalSeconds}s";
+
         var tokensResult = await ExecAsync(command, ct)
             .ConfigureAwait(false);
 

tests/Testcontainers.Pulsar.Tests/PulsarContainerTest.cs

@@ -79,7 +79,7 @@ public PulsarAuthConfiguration()
 
         protected override async Task<IPulsarClient> CreateClientAsync(CancellationToken ct = default)
         {
-            var authToken = await _pulsarContainer.CreateAuthenticationTokenAsync(TimeSpan.FromDays(365), ct)
+            var authToken = await _pulsarContainer.CreateAuthenticationTokenAsync(TimeSpan.FromHours(1), ct)
                 .ConfigureAwait(false);
 
             return PulsarClient.Builder().ServiceUrl(new Uri(_pulsarContainer.GetBrokerAddress())).Authentication(new TokenAuthentication(authToken)).Build();