This is an automated email from the ASF dual-hosted git repository.
onobc pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pulsar-client-reactive.git
The following commit(s) were added to refs/heads/main by this push:
new 9127e85 Upgrade Pulsar to 3.3.1 (#179)
9127e85 is described below
commit 9127e85cffed78eb7eadd9024780c7bffd7d4bfc
Author: Lari Hotari <[email protected]>
AuthorDate: Fri Aug 2 19:01:45 2024 +0300
Upgrade Pulsar to 3.3.1 (#179)
---
gradle/libs.versions.toml | 2 +-
.../pulsar/reactive/client/adapter/SingletonPulsarContainer.java | 2 +-
.../client/internal/adapter/AdaptedReactiveMessageConsumerTests.java | 3 ++-
scripts/validate_staging_repo.sh | 4 ++--
4 files changed, 6 insertions(+), 5 deletions(-)
diff --git a/gradle/libs.versions.toml b/gradle/libs.versions.toml
index cb8656e..b22db4a 100644
--- a/gradle/libs.versions.toml
+++ b/gradle/libs.versions.toml
@@ -29,7 +29,7 @@ junit-jupiter = "5.11.0-M2"
licenser = "0.6.1"
log4j = "2.23.1"
mockito = "5.12.0"
-pulsar = "3.2.3"
+pulsar = "3.3.1"
rat-gradle = "0.8.0"
reactor = "3.6.7"
slf4j = "2.0.13"
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 2d1e316..8337a82 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 @@ final class SingletonPulsarContainer {
}
static DockerImageName getPulsarImage() {
- return DockerImageName.parse("apachepulsar/pulsar:3.2.3");
+ return DockerImageName.parse("apachepulsar/pulsar:3.3.1");
}
}
diff --git
a/pulsar-client-reactive-adapter/src/test/java/org/apache/pulsar/reactive/client/internal/adapter/AdaptedReactiveMessageConsumerTests.java
b/pulsar-client-reactive-adapter/src/test/java/org/apache/pulsar/reactive/client/internal/adapter/AdaptedReactiveMessageConsumerTests.java
index 2fbc7da..3545d1d 100644
---
a/pulsar-client-reactive-adapter/src/test/java/org/apache/pulsar/reactive/client/internal/adapter/AdaptedReactiveMessageConsumerTests.java
+++
b/pulsar-client-reactive-adapter/src/test/java/org/apache/pulsar/reactive/client/internal/adapter/AdaptedReactiveMessageConsumerTests.java
@@ -57,6 +57,7 @@ import reactor.test.StepVerifier;
import static org.assertj.core.api.Assertions.assertThat;
import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.ArgumentMatchers.anyBoolean;
import static org.mockito.ArgumentMatchers.anyString;
import static org.mockito.ArgumentMatchers.eq;
import static org.mockito.ArgumentMatchers.isNull;
@@ -77,7 +78,7 @@ class AdaptedReactiveMessageConsumerTests {
PulsarClientImpl pulsarClient = spy(
(PulsarClientImpl)
PulsarClient.builder().serviceUrl("http://dummy";).build());
doReturn(CompletableFuture.completedFuture(new
PartitionedTopicMetadata())).when(pulsarClient)
- .getPartitionedTopicMetadata(anyString());
+ .getPartitionedTopicMetadata(anyString(), anyBoolean());
Consumer<String> consumer = mock(Consumer.class);
doReturn(CompletableFuture.completedFuture(null)).when(consumer).closeAsync();
diff --git a/scripts/validate_staging_repo.sh b/scripts/validate_staging_repo.sh
index 1f16172..b828928 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.2.3}
+: ${DOCKER_IMAGE_NAME:=apachepulsar/pulsar:3.3.1}
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.2.3
/pulsar/bin/pulsar standalone -nss -nfw
+ // docker run -it -p 8080:8080 -p 6650:6650 apachepulsar/pulsar:3.3.1
/pulsar/bin/pulsar standalone -nss -nfw
try (PulsarClient pulsarClient =
PulsarClient.builder().serviceUrl("pulsar://localhost:6650").build()) {
