From cc27d87cc882d06ed55f68eba05a17fa46b6ac83 Mon Sep 17 00:00:00 2001 From: Chris Bono Date: Mon, 5 Feb 2024 10:10:49 -0600 Subject: [PATCH] Update Pulsar to 3.2.0 (#159) Resolves #157 Co-authored-by: onobc --- gradle/libs.versions.toml | 2 +- .../reactive/client/adapter/SingletonPulsarContainer.java | 2 +- scripts/validate_staging_repo.sh | 4 ++-- 3 files changed, 4 insertions(+), 4 deletions(-) diff --git a/gradle/libs.versions.toml b/gradle/libs.versions.toml index 250931d..7368aaa 100644 --- a/gradle/libs.versions.toml +++ b/gradle/libs.versions.toml @@ -29,7 +29,7 @@ junit-jupiter = "5.10.1" licenser = "0.6.1" log4j = "2.22.1" mockito = "5.8.0" -pulsar = "3.1.2" +pulsar = "3.2.0" rat-gradle = "0.8.0" reactor = "3.6.2" slf4j = "2.0.11" diff --git a/pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/SingletonPulsarContainer.java b/pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/SingletonPulsarContainer.java index a49e268..539e803 100644 --- a/pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/SingletonPulsarContainer.java +++ b/pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/SingletonPulsarContainer.java @@ -45,7 +45,7 @@ static PulsarClient createPulsarClient() throws PulsarClientException { } static DockerImageName getPulsarImage() { - return DockerImageName.parse("apachepulsar/pulsar:3.1.2"); + return DockerImageName.parse("apachepulsar/pulsar:3.2.0"); } } diff --git a/scripts/validate_staging_repo.sh b/scripts/validate_staging_repo.sh index 09683c6..6584f90 100755 --- a/scripts/validate_staging_repo.sh +++ b/scripts/validate_staging_repo.sh @@ -40,7 +40,7 @@ if ! command -v gradle &>/dev/null; then fi DOCKER_CONTAINER_NAME=pulsar-standalone-$$ -: ${DOCKER_IMAGE_NAME:=apachepulsar/pulsar:3.1.2} +: ${DOCKER_IMAGE_NAME:=apachepulsar/pulsar:3.2.0} mkdir test-app-reactive-$$ cd test-app-reactive-$$ @@ -90,7 +90,7 @@ public class HelloPulsarClientReactive { public static void main(String[] args) throws PulsarClientException, InterruptedException { // Before running this, start Pulsar within docker with this command: - // docker run -it -p 8080:8080 -p 6650:6650 apachepulsar/pulsar:3.1.2 /pulsar/bin/pulsar standalone -nss -nfw + // docker run -it -p 8080:8080 -p 6650:6650 apachepulsar/pulsar:3.2.0 /pulsar/bin/pulsar standalone -nss -nfw try (PulsarClient pulsarClient = PulsarClient.builder().serviceUrl("pulsar://localhost:6650").build()) {