From db0125e657b2d790cc4a6121017c973c8c301af5 Mon Sep 17 00:00:00 2001 From: onobc Date: Tue, 7 Oct 2025 12:17:32 -0500 Subject: [PATCH] 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 --- gradle/libs.versions.toml | 2 +- .../sample-failover-custom-router/compose.yaml | 2 +- .../sample-imperative-produce-consume/compose.yaml | 2 +- spring-pulsar-sample-apps/sample-pulsar-binder/compose.yaml | 2 +- .../sample-pulsar-functions/download-connectors.sh | 4 ++-- spring-pulsar-sample-apps/sample-pulsar-reader/compose.yaml | 2 +- spring-pulsar-sample-apps/sample-reactive/compose.yaml | 2 +- .../pulsar/test/support/PulsarTestContainerSupport.java | 2 +- .../pulsar/core/CachingPulsarProducerFactory.java | 5 +++++ tools/pulsar/docker/standalone/pulsar-start.sh | 2 +- 10 files changed, 15 insertions(+), 10 deletions(-) diff --git a/gradle/libs.versions.toml b/gradle/libs.versions.toml index 7fbe1bdc..9a73ae68 100644 --- a/gradle/libs.versions.toml +++ b/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" diff --git a/spring-pulsar-sample-apps/sample-failover-custom-router/compose.yaml b/spring-pulsar-sample-apps/sample-failover-custom-router/compose.yaml index 2e67c846..d79eca86 100644 --- a/spring-pulsar-sample-apps/sample-failover-custom-router/compose.yaml +++ b/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' diff --git a/spring-pulsar-sample-apps/sample-imperative-produce-consume/compose.yaml b/spring-pulsar-sample-apps/sample-imperative-produce-consume/compose.yaml index 2e67c846..d79eca86 100644 --- a/spring-pulsar-sample-apps/sample-imperative-produce-consume/compose.yaml +++ b/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' diff --git a/spring-pulsar-sample-apps/sample-pulsar-binder/compose.yaml b/spring-pulsar-sample-apps/sample-pulsar-binder/compose.yaml index 2e67c846..d79eca86 100644 --- a/spring-pulsar-sample-apps/sample-pulsar-binder/compose.yaml +++ b/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' diff --git a/spring-pulsar-sample-apps/sample-pulsar-functions/download-connectors.sh b/spring-pulsar-sample-apps/sample-pulsar-functions/download-connectors.sh index 47649db1..429a4ed6 100755 --- a/spring-pulsar-sample-apps/sample-pulsar-functions/download-connectors.sh +++ b/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 .. diff --git a/spring-pulsar-sample-apps/sample-pulsar-reader/compose.yaml b/spring-pulsar-sample-apps/sample-pulsar-reader/compose.yaml index 2e67c846..d79eca86 100644 --- a/spring-pulsar-sample-apps/sample-pulsar-reader/compose.yaml +++ b/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' diff --git a/spring-pulsar-sample-apps/sample-reactive/compose.yaml b/spring-pulsar-sample-apps/sample-reactive/compose.yaml index 2e67c846..d79eca86 100644 --- a/spring-pulsar-sample-apps/sample-reactive/compose.yaml +++ b/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' diff --git a/spring-pulsar-test/src/main/java/org/springframework/pulsar/test/support/PulsarTestContainerSupport.java b/spring-pulsar-test/src/main/java/org/springframework/pulsar/test/support/PulsarTestContainerSupport.java index 0eda10ab..e8fcdf01 100644 --- a/spring-pulsar-test/src/main/java/org/springframework/pulsar/test/support/PulsarTestContainerSupport.java +++ b/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 diff --git a/spring-pulsar/src/main/java/org/springframework/pulsar/core/CachingPulsarProducerFactory.java b/spring-pulsar/src/main/java/org/springframework/pulsar/core/CachingPulsarProducerFactory.java index 233e8f52..f43d533a 100644 --- a/spring-pulsar/src/main/java/org/springframework/pulsar/core/CachingPulsarProducerFactory.java +++ b/spring-pulsar/src/main/java/org/springframework/pulsar/core/CachingPulsarProducerFactory.java @@ -296,6 +296,11 @@ public TypedMessageBuilder newMessage(Transaction txn) { return this.producer.newMessage(txn); } + @Override + public TypedMessageBuilder newMessage(Schema schema, Transaction txn) { + return this.producer.newMessage(schema, txn); + } + @Override public long getLastSequenceId() { return this.producer.getLastSequenceId(); diff --git a/tools/pulsar/docker/standalone/pulsar-start.sh b/tools/pulsar/docker/standalone/pulsar-start.sh index ef016e81..64217d04 100755 --- a/tools/pulsar/docker/standalone/pulsar-start.sh +++ b/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