Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[fix] [broker] response not-found error if topic does not exist when calling getPartitionedTopicMetadata #22838

Merged
merged 20 commits into from
Jun 17, 2024
Merged

[fix] [broker] response not-found error if topic does not exist when calling getPartitionedTopicMetadata #22838

Changes from 1 commit
Commits
Show all changes
20 commits
Select commit Hold shift + click to select a range
24959d0
[fix] [broker] response not-found error if topic does not exist when …
poorbarcode Jun 4, 2024
06a0b15
checkstyle
poorbarcode Jun 4, 2024
bc5bcea
fix test
poorbarcode Jun 6, 2024
653272f
addrees comment
poorbarcode Jun 6, 2024
08f02a4
address comment
poorbarcode Jun 6, 2024
f209eab
fix tests
poorbarcode Jun 6, 2024
d111bd2
fix tests
poorbarcode Jun 6, 2024
3911aba
fix tests
poorbarcode Jun 6, 2024
02416de
fix tests
poorbarcode Jun 6, 2024
3bdfe97
add a test case: topic with suffix -partition-1
poorbarcode Jun 6, 2024
f0677a9
add a test case: topic with suffix -partition-1
poorbarcode Jun 6, 2024
dab61e1
fix tests
poorbarcode Jun 7, 2024
ba0d3e6
fix compatibility for old DLQ
poorbarcode Jun 7, 2024
4b5fb5d
checkstyle
poorbarcode Jun 7, 2024
3e061cc
fix tests
poorbarcode Jun 7, 2024
78468dd
address comments
poorbarcode Jun 11, 2024
b1c32dc
improve the logic for DLQ
poorbarcode Jun 11, 2024
1e7319c
remove the param assumedNonPartitionedNonPersistentTopicAlwaysExists
poorbarcode Jun 11, 2024
a244d98
add code description
poorbarcode Jun 11, 2024
346adcc
check style
poorbarcode Jun 11, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
fix tests
  • Loading branch information
@poorbarcode
poorbarcode committed Jun 11, 2024
commit 3e061cc53c79fe62f1aa5681aec82e502b10b06b
4 changes: 4 additions & 0 deletions pulsar-broker/src/test/java/org/apache/pulsar/broker/lookup/http/HttpTopicLookupv2Test.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -270,6 +270,10 @@ public void testValidateReplicationSettingsOnNamespace() throws Exception {
CompletableFuture<TopicExistsInfo> future = new CompletableFuture<>();
future.complete(TopicExistsInfo.notExists());
doReturn(future).when(namespaceService).checkTopicExists(any(TopicName.class));
doReturn(future).when(namespaceService).checkTopicExists(any(TopicName.class), anyBoolean());
CompletableFuture<Boolean> booleanFuture = new CompletableFuture<>();
booleanFuture.complete(false);
doReturn(future).when(namespaceService).checkNonPartitionedTopicExists(any(TopicName.class), anyBoolean());
destLookup.lookupTopicAsync(asyncResponse, TopicDomain.persistent.value(), property, cluster, ns2,
"invalid-localCluster", false, null, null);
verify(asyncResponse).resume(arg.capture());
Expand Down
Loading