(pulsar) branch master updated: [improve][admin] Print error log if handle http response fails (#23563)

[technoboy]

This is an automated email from the ASF dual-hosted git repository.

technoboy pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new c15a0d69823 [improve][admin] Print error log if handle http response 
fails (#23563)
c15a0d69823 is described below

commit c15a0d698231ec697f3ec45f7f09eb904d56758c
Author: fengyubiao <yubiao.f...@streamnative.io>
AuthorDate: Wed Nov 6 09:37:21 2024 +0800

    [improve][admin] Print error log if handle http response fails (#23563)
---
 .../pulsar/client/admin/internal/http/AsyncHttpConnector.java       | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

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 de694534a9e..b04c19b7ded 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 class AsyncHttpConnector implements Connector, 
AsyncHttpRequestExecutor {
                 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;