Skip to content

Commit

Permalink
[Broker] Ignore the print the log that the topic does not exist (apac…
Browse files Browse the repository at this point in the history
  • Loading branch information
nodece authored Mar 14, 2022
1 parent 3afd1e6 commit fe7e55d
Showing 1 changed file with 3 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -4554,8 +4554,9 @@ protected CompletableFuture<Void> internalRemoveSubscribeRate(boolean isGlobal)

protected void handleTopicPolicyException(String methodName, Throwable thr, AsyncResponse asyncResponse) {
Throwable cause = thr.getCause();
if (!(cause instanceof WebApplicationException)
|| !(((WebApplicationException) cause).getResponse().getStatus() == 307)) {
if (!(cause instanceof WebApplicationException) || !(
((WebApplicationException) cause).getResponse().getStatus() == 307
|| ((WebApplicationException) cause).getResponse().getStatus() == 404)) {
log.error("[{}] Failed to perform {} on topic {}",
clientAppId(), methodName, topicName, cause);
}
Expand Down

0 comments on commit fe7e55d

Please sign in to comment.