Skip to content

Commit 2c6c915

Browse files
entvexDavid Erik Jensen
andauthored
fix(Pulsar): Support Apache Pulsar 4 (#1355)
Co-authored-by: David Erik Jensen <[email protected]>
1 parent 888da44 commit 2c6c915

File tree

3 files changed

+21
-3
lines changed

3 files changed

+21
-3
lines changed

src/Testcontainers.Pulsar/PulsarBuilder.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -4,15 +4,15 @@ namespace Testcontainers.Pulsar;
44
[PublicAPI]
55
public sealed class PulsarBuilder : ContainerBuilder<PulsarBuilder, PulsarContainer, PulsarConfiguration>
66
{
7-
public const string PulsarImage = "apachepulsar/pulsar:3.0.6";
7+
public const string PulsarImage = "apachepulsar/pulsar:3.0.9";
88

99
public const ushort PulsarBrokerDataPort = 6650;
1010

1111
public const ushort PulsarWebServicePort = 8080;
1212

1313
public const string StartupScriptFilePath = "/testcontainers.sh";
1414

15-
public const string SecretKeyFilePath = "/pulsar/secret.key";
15+
public const string SecretKeyFilePath = "/tmp/secret.key";
1616

1717
public const string Username = "test-user";
1818

src/Testcontainers.Pulsar/PulsarContainer.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -105,7 +105,7 @@ internal Task CopyStartupScriptAsync(CancellationToken ct = default)
105105
startupScript.WriteLine("export brokerClientAuthenticationParameters=token:$(bin/pulsar tokens create --secret-key $PULSAR_PREFIX_tokenSecretKey --subject $superUserRoles)");
106106
startupScript.WriteLine("export CLIENT_PREFIX_authParams=$brokerClientAuthenticationParameters");
107107
startupScript.WriteLine("bin/apply-config-from-env.py conf/standalone.conf");
108-
startupScript.WriteLine("bin/apply-config-from-env-with-prefix.py CLIENT_PREFIX_ conf/client.conf");
108+
startupScript.WriteLine("bin/apply-config-from-env.py --prefix CLIENT_PREFIX_ conf/client.conf");
109109
}
110110

111111
startupScript.Write("bin/pulsar standalone");

tests/Testcontainers.Pulsar.Tests/PulsarContainerTest.cs

Lines changed: 18 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -84,4 +84,22 @@ public PulsarAuthConfiguration()
8484
{
8585
}
8686
}
87+
88+
[UsedImplicitly]
89+
public sealed class PulsarDefaultConfigurationLts4 : PulsarContainerTest
90+
{
91+
public PulsarDefaultConfigurationLts4()
92+
: base(new PulsarBuilder().WithImage("apachepulsar/pulsar:4.0.2").Build(), false)
93+
{
94+
}
95+
}
96+
97+
[UsedImplicitly]
98+
public sealed class PulsarAuthConfigurationLts4 : PulsarContainerTest
99+
{
100+
public PulsarAuthConfigurationLts4()
101+
: base(new PulsarBuilder().WithImage("apachepulsar/pulsar:4.0.2").WithAuthentication().Build(), true)
102+
{
103+
}
104+
}
87105
}

0 commit comments

Comments
 (0)