You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by pe...@apache.org on 2021/12/21 01:33:39 UTC
[pulsar] 03/18: [Java Client] Avoid IllegalStateException in ClientCnx debug logs (#12899)
This is an automated email from the ASF dual-hosted git repository.
penghui pushed a commit to branch branch-2.9
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 4954c09e87be2672ffe04f3a18487c7507484ed7
Author: Michael Marshall <mi...@datastax.com>
AuthorDate: Mon Nov 22 04:45:52 2021 -0500
[Java Client] Avoid IllegalStateException in ClientCnx debug logs (#12899)
(cherry picked from commit 32b697d3adb18ecc9992f6dfbf9ac13158649af3)
---
.../src/main/java/org/apache/pulsar/client/impl/ClientCnx.java | 10 ++++++++--
1 file changed, 8 insertions(+), 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
index e2386a9..cae1594 100644
--- 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
@@ -543,7 +543,9 @@ public class ClientCnx extends PulsarHandler {
@Override
protected void handleLookupResponse(CommandLookupTopicResponse lookupResult) {
if (log.isDebugEnabled()) {
- log.debug("Received Broker lookup response: {}", lookupResult.getResponse());
+ CommandLookupTopicResponse.LookupType response =
+ lookupResult.hasResponse() ? lookupResult.getResponse() : null;
+ log.debug("Received Broker lookup response: {} {}", lookupResult.getRequestId(), response);
}
long requestId = lookupResult.getRequestId();
@@ -579,7 +581,11 @@ public class ClientCnx extends PulsarHandler {
@Override
protected void handlePartitionResponse(CommandPartitionedTopicMetadataResponse lookupResult) {
if (log.isDebugEnabled()) {
- log.debug("Received Broker Partition response: {}", lookupResult.getPartitions());
+ CommandPartitionedTopicMetadataResponse.LookupType response =
+ lookupResult.hasResponse() ? lookupResult.getResponse() : null;
+ int partitions = lookupResult.hasPartitions() ? lookupResult.getPartitions() : -1;
+ log.debug("Received Broker Partition response: {} {} {}", lookupResult.getRequestId(), response,
+ partitions);
}
long requestId = lookupResult.getRequestId();