diff --git a/pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/http/AsyncHttpConnector.java b/pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/http/AsyncHttpConnector.java index de694534a9e25d..b04c19b7ded45c 100644 --- a/pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/http/AsyncHttpConnector.java +++ b/pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/http/AsyncHttpConnector.java @@ -272,7 +272,11 @@ public String getReasonPhrase() { if (response.hasResponseBody()) { jerseyResponse.setEntityStream(response.getResponseBodyAsStream()); } - callback.response(jerseyResponse); + try { + callback.response(jerseyResponse); + } catch (Exception ex) { + log.error("failed to handle the http response {}", jerseyResponse, ex); + } } })); return responseFuture;