Use pulsar container 4.0.0

smallrye · Nov 26, 2024 · e142a27 · e142a27
1 parent 9687ccb
commit e142a27
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/...g-pulsar/src/test/java/io/smallrye/reactive/messaging/pulsar/ConcurrentProcessorTest.java b/...g-pulsar/src/test/java/io/smallrye/reactive/messaging/pulsar/ConcurrentProcessorTest.java
@@ -39,7 +39,7 @@ private MapBasedConfig dataconfig() {
                 .with("mp.messaging.incoming.data.subscriptionInitialPosition", SubscriptionInitialPosition.Earliest)
                 .with("mp.messaging.incoming.data.subscriptionName", topic + "-subscription")
                 .with("mp.messaging.incoming.data.subscriptionType", SubscriptionType.Key_Shared)
-                .with("mp.messaging.incoming.data.concurrency", 3);
+                .with("mp.messaging.incoming.data.concurrency", 6); // TODO Since Pulsar 4.0 at least one consumer is always idle
     }
 
     @Test

diff --git a/...ging-pulsar/src/test/java/io/smallrye/reactive/messaging/pulsar/base/PulsarContainer.java b/...ging-pulsar/src/test/java/io/smallrye/reactive/messaging/pulsar/base/PulsarContainer.java
@@ -12,7 +12,7 @@
 
 public class PulsarContainer extends GenericContainer<PulsarContainer> {
 
-    public static final DockerImageName PULSAR_IMAGE = DockerImageName.parse("apachepulsar/pulsar:3.3.2");
+    public static final DockerImageName PULSAR_IMAGE = DockerImageName.parse("apachepulsar/pulsar:4.0.0");
 
     public static final String STARTER_SCRIPT = "/run_pulsar.sh";