diff --git a/gradle.properties b/gradle.properties index 101540a3..f777d277 100644 --- a/gradle.properties +++ b/gradle.properties @@ -4,7 +4,7 @@ org.gradle.caching=true org.gradle.parallel=true org.gradle.jvmargs=-Xmx4g -XX:+HeapDumpOnOutOfMemoryError -XX:+UseParallelGC -Dfile.encoding=UTF-8 -pulsarClientVersion=3.1.0 +pulsarClientVersion=3.1.1 pulsarClientReactiveVersion=0.5.0 springFrameworkVersion=6.1.0 diff --git a/integration-tests/integration-tests.gradle b/integration-tests/integration-tests.gradle index a169ce8e..7a01affe 100644 --- a/integration-tests/integration-tests.gradle +++ b/integration-tests/integration-tests.gradle @@ -43,8 +43,8 @@ task downloadRabbitConnector { try { download.run { println "Downloading Rabbit connector to 'src/intTest/resources/connectors/' (one time only if not already downloaded)..." - src 'https://archive.apache.org/dist/pulsar/pulsar-3.1.0/connectors/pulsar-io-rabbitmq-3.1.0.nar' - dest "$buildDir/../src/intTest/resources/connectors/pulsar-io-rabbitmq-3.1.0.nar" + src 'https://archive.apache.org/dist/pulsar/pulsar-3.1.1/connectors/pulsar-io-rabbitmq-3.1.1.nar' + dest "$buildDir/../src/intTest/resources/connectors/pulsar-io-rabbitmq-3.1.1.nar" overwrite false } } catch (Exception ex) { 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 c264e05d..2c6e85e7 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-3.1.0/connectors/pulsar-io-cassandra-3.1.0.nar -wget https://archive.apache.org/dist/pulsar/pulsar-3.1.0/connectors/pulsar-io-rabbitmq-3.1.0.nar +wget https://archive.apache.org/dist/pulsar/pulsar-3.1.1/connectors/pulsar-io-cassandra-3.1.1.nar +wget https://archive.apache.org/dist/pulsar/pulsar-3.1.1/connectors/pulsar-io-rabbitmq-3.1.1.nar cd .. diff --git a/spring-pulsar-sample-apps/sample-pulsar-functions/sample-signup-function/build.gradle b/spring-pulsar-sample-apps/sample-pulsar-functions/sample-signup-function/build.gradle index b0901c7b..f423d73f 100644 --- a/spring-pulsar-sample-apps/sample-pulsar-functions/sample-signup-function/build.gradle +++ b/spring-pulsar-sample-apps/sample-pulsar-functions/sample-signup-function/build.gradle @@ -11,8 +11,8 @@ repositories { } dependencies { - implementation 'org.apache.pulsar:pulsar-client-all:3.1.0' - implementation 'org.apache.pulsar:pulsar-functions-api:3.1.0' + implementation 'org.apache.pulsar:pulsar-client-all:3.1.1' + implementation 'org.apache.pulsar:pulsar-functions-api:3.1.1' compileOnly 'org.projectlombok:lombok:1.18.24' annotationProcessor 'org.projectlombok:lombok:1.18.24' } 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 115a7b86..cb4e4b34 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 @@ -41,7 +41,7 @@ public interface PulsarTestContainerSupport { } static DockerImageName getPulsarImage() { - return DockerImageName.parse("apachepulsar/pulsar:3.1.0"); + return DockerImageName.parse("apachepulsar/pulsar:3.1.1"); } static String getHttpServiceUrl() { diff --git a/tools/pulsar/docker/standalone/pulsar-start.sh b/tools/pulsar/docker/standalone/pulsar-start.sh index 5b735c44..982fe08f 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:3.1.0 \ + apachepulsar/pulsar:3.1.1 \ bin/pulsar standalone