Update to Pulsar 4.1.1

This updates the Pulsar client library from `4.1.0` to `4.1.1`.

The new version of the client introduces a new method on the `Producer` interface.
This requires our `CachingPulsarProducerfactory` implementation to also add the
method.

Signed-off-by: onobc <[email protected]>

Author: onobc

gradle/libs.versions.toml

@@ -10,7 +10,7 @@ micrometer = "1.16.0-M3"
 micrometer-docs-gen = "1.0.4"
 micrometer-tracing = "1.6.0-M3"
 protobuf = "3.25.8"
-pulsar = "4.1.0"
+pulsar = "4.1.1"
 pulsar-reactive = "0.7.0"
 reactor = "2025.0.0-M7"
 spring = "7.0.0-M9"

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

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

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

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

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

@@ -1,6 +1,6 @@
 services:
   pulsar:
-    image: 'apachepulsar/pulsar:4.1.0'
+    image: 'apachepulsar/pulsar:4.1.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-4.1.0/connectors/pulsar-io-cassandra-4.1.0.nar
-wget https://archive.apache.org/dist/pulsar/pulsar-4.1.0/connectors/pulsar-io-rabbitmq-4.1.0.nar
+wget https://archive.apache.org/dist/pulsar/pulsar-4.1.1/connectors/pulsar-io-cassandra-4.1.1.nar
+wget https://archive.apache.org/dist/pulsar/pulsar-4.1.1/connectors/pulsar-io-rabbitmq-4.1.1.nar
 cd ..

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

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

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

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

spring-pulsar-test/src/main/java/org/springframework/pulsar/test/support/PulsarTestContainerSupport.java

@@ -33,7 +33,7 @@ public interface PulsarTestContainerSupport {
 	PulsarContainer PULSAR_CONTAINER = new PulsarContainer(getPulsarImage());
 
 	static DockerImageName getPulsarImage() {
-		return DockerImageName.parse("apachepulsar/pulsar:4.1.0");
+		return DockerImageName.parse("apachepulsar/pulsar:4.1.1");
 	}
 
 	@BeforeAll

spring-pulsar/src/main/java/org/springframework/pulsar/core/CachingPulsarProducerFactory.java

@@ -296,6 +296,11 @@ public TypedMessageBuilder<T> newMessage(Transaction txn) {
 			return this.producer.newMessage(txn);
 		}
 
+		@Override
+		public <V> TypedMessageBuilder<V> newMessage(Schema<V> schema, Transaction txn) {
+			return this.producer.newMessage(schema, txn);
+		}
+
 		@Override
 		public long getLastSequenceId() {
 			return this.producer.getLastSequenceId();

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:4.1.0 \
+  apachepulsar/pulsar:4.1.1 \
   bin/pulsar standalone