Skip to content

Commit

Permalink
[fix][broker] revert remove duplicate topics name when deleteNamespace (
Browse files Browse the repository at this point in the history
  • Loading branch information
TakaHiR07 authored and Technoboy- committed Sep 5, 2023
1 parent acb5a54 commit 15b7508
Showing 1 changed file with 0 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -280,12 +280,6 @@ private void internalRetryableDeleteNamespaceAsync0(boolean force, int retryTime
return old;
});
}
allUserCreatedTopics.removeIf(t ->
allPartitionedTopics.contains(TopicName.get(t).getPartitionedTopicName()));
allSystemTopics.removeIf(t ->
allPartitionedTopics.contains(TopicName.get(t).getPartitionedTopicName()));
topicPolicy.removeIf(t ->
allPartitionedTopics.contains(TopicName.get(t).getPartitionedTopicName()));
return markDeleteFuture.thenCompose(__ ->
internalDeleteTopicsAsync(allUserCreatedTopics))
.thenCompose(ignore ->
Expand Down

0 comments on commit 15b7508

Please sign in to comment.