Update to Pulsar 4.1.0

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

Author: onobc

.github/workflows/check-samples.yml

@@ -59,7 +59,7 @@ jobs:
           - javaVersion: 17
             springBootVersion: "${{ needs.prerequisites.outputs.boot_version }}"
             springPulsarVersion: "${{ needs.prerequisites.outputs.project_version }}"
-            pulsarVersion: "4.0.1"
+            pulsarVersion: "4.1.0"
             samplesTarget: ':runAllSampleTests'
     runs-on: ubuntu-latest
     if: needs.prerequisites.outputs.runjobs

gradle/libs.versions.toml

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

spring-pulsar-docs/src/main/antora/modules/ROOT/pages/appendix/version-compatibility.adoc

@@ -8,7 +8,7 @@ The following is the compatibility matrix:
 | Spring for Apache Pulsar | Pulsar Client | Pulsar Reactive Client | Spring Boot | Java
 
 | 2.0.x
-| 3.3.x / 4.0.x^**(*)**^
+| 4.1.x / 4.0.x / 3.3.x
 | 0.5.x - 0.7.x
 | 4.0.x
 | 17+
@@ -36,7 +36,7 @@ The following is the compatibility matrix:
 [NOTE]
 ====
 ^**(*)**^ The `3.3.x` Pulsar client is the default version specified by Spring for Apache Pulsar `1.2.x` and Spring Boot `3.4.x`.
-However, the `4.0.x` Pulsar client is compatible and will be the default version in the next minor releases (`1.3.x` and `3.5.x`, respectively).
+However, the `4.0.x` Pulsar client is compatible.
 
 You can follow xref:appendix/override-boot-dependencies.adoc#override-boot-deps[these steps] to override the Pulsar client version.
 ====

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

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

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

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

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

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

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

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

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

@@ -1,6 +1,6 @@
 services:
   pulsar:
-    image: 'apachepulsar/pulsar:4.0.6'
+    image: 'apachepulsar/pulsar:4.1.0'
     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.0.6");
+		return DockerImageName.parse("apachepulsar/pulsar:4.1.0");
 	}
 
 	@BeforeAll