Skip to content

Commit fb53ad9

Browse files
committed
Fix compilation in test due to Pulsar 3.3.2 update
1 parent 1dccd9f commit fb53ad9

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

pulsar-client-reactive-adapter/src/test/java/org/apache/pulsar/reactive/client/internal/adapter/AdaptedReactiveMessageConsumerTests.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -78,7 +78,7 @@ void consumerProperties() throws Exception {
7878
PulsarClientImpl pulsarClient = spy(
7979
(PulsarClientImpl) PulsarClient.builder().serviceUrl("http://dummy").build());
8080
doReturn(CompletableFuture.completedFuture(new PartitionedTopicMetadata())).when(pulsarClient)
81-
.getPartitionedTopicMetadata(anyString(), anyBoolean());
81+
.getPartitionedTopicMetadata(anyString(), anyBoolean(), anyBoolean());
8282

8383
Consumer<String> consumer = mock(Consumer.class);
8484
doReturn(CompletableFuture.completedFuture(null)).when(consumer).closeAsync();

0 commit comments

Comments
 (0)