resolved comment

streamnative · Nov 6, 2023 · c30eae1 · c30eae1
1 parent c0eec1e
commit c30eae1
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ClientCnx.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ClientCnx.java
@@ -814,13 +814,13 @@ protected void handleCloseProducer(CommandCloseProducer closeProducer) {
                             remoteAddress, closeProducer.getProducerId(), uri);
                     producer.getConnectionHandler().connectionClosed(
                             this, Optional.of(0L), Optional.of(uri));
-                } catch (URISyntaxException e) {
+                } catch (Throwable e) {
                     log.error("[{}] Invalid redirect url {}/{} for {}", remoteAddress,
                             closeProducer.hasAssignedBrokerServiceUrl()
                                     ? closeProducer.getAssignedBrokerServiceUrl() : "",
                             closeProducer.hasAssignedBrokerServiceUrlTls()
                                     ? closeProducer.getAssignedBrokerServiceUrlTls() : "",
-                            closeProducer.getRequestId());
+                            closeProducer.getRequestId(), e);
                     producer.connectionClosed(this);
                 }
             } else {