[WIP] Update to Pulsar 4.0.1

gradle/libs.versions.toml

@@ -9,7 +9,7 @@ micrometer = "1.14.2"
 micrometer-docs-gen = "1.0.4"
 micrometer-tracing = "1.4.1"
 protobuf = "3.25.5"
-pulsar = "3.3.3"
+pulsar = "4.0.1"
 pulsar-reactive = "0.5.9"
 reactor = "2024.0.1"
 spring = "6.2.1"

spring-pulsar-sample-apps/sample-failover-custom-router/compose.yaml

@@ -1,6 +1,6 @@
 services:
   pulsar:
-    image: 'apachepulsar/pulsar:3.3.3'
+    image: 'apachepulsar/pulsar:4.0.1'
     ports:
       - '6650'
       - '8080'

spring-pulsar-sample-apps/sample-imperative-produce-consume/compose.yaml

@@ -1,6 +1,6 @@
 services:
   pulsar:
-    image: 'apachepulsar/pulsar:3.3.3'
+    image: 'apachepulsar/pulsar:4.0.1'
     ports:
       - '6650'
       - '8080'

spring-pulsar-sample-apps/sample-pulsar-binder/compose.yaml

@@ -1,6 +1,6 @@
 services:
   pulsar:
-    image: 'apachepulsar/pulsar:3.3.3'
+    image: 'apachepulsar/pulsar:4.0.1'
     ports:
       - '6650'
       - '8080'

spring-pulsar-sample-apps/sample-pulsar-functions/download-connectors.sh

@@ -2,6 +2,6 @@
 
 mkdir connectors
 cd connectors
-wget https://archive.apache.org/dist/pulsar/pulsar-3.3.3/connectors/pulsar-io-cassandra-3.3.3.nar
-wget https://archive.apache.org/dist/pulsar/pulsar-3.3.3/connectors/pulsar-io-rabbitmq-3.3.3.nar
+wget https://archive.apache.org/dist/pulsar/pulsar-4.0.1/connectors/pulsar-io-cassandra-4.0.1.nar
+wget https://archive.apache.org/dist/pulsar/pulsar-4.0.1/connectors/pulsar-io-rabbitmq-4.0.1.nar
 cd ..

spring-pulsar-sample-apps/sample-pulsar-reader/compose.yaml

@@ -1,6 +1,6 @@
 services:
   pulsar:
-    image: 'apachepulsar/pulsar:3.3.3'
+    image: 'apachepulsar/pulsar:4.0.1'
     ports:
       - '6650'
       - '8080'

spring-pulsar-sample-apps/sample-reactive/compose.yaml

@@ -1,6 +1,6 @@
 services:
   pulsar:
-    image: 'apachepulsar/pulsar:3.3.3'
+    image: 'apachepulsar/pulsar:4.0.1'
     ports:
       - '6650'
       - '8080'

spring-pulsar/src/test/java/org/springframework/pulsar/reader/PulsarReaderStartMessageIdTests.java

@@ -79,7 +79,7 @@ void startMessageIdMissing() {
 					PulsarReaderStartMessageIdMissing.class))
 				.rootCause()
 				.isInstanceOf(IllegalArgumentException.class)
-				.hasMessage(
+				.hasMessageStartingWith(
 						"Start message id or start message from roll back must be specified but they cannot be specified at the same time");
 		}
 

tools/pulsar/docker/standalone/pulsar-start.sh

@@ -3,5 +3,5 @@
 docker run -it -p 6650:6650 -p 8080:8080 \
   --mount source=pulsardata,target=/pulsar/data \
   --mount source=pulsarconf,target=/pulsar/conf \
-  apachepulsar/pulsar:3.3.3 \
+  apachepulsar/pulsar:4.0.1 \
   bin/pulsar standalone