You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by te...@apache.org on 2023/09/11 04:35:28 UTC
[pulsar] branch branch-2.11 updated: [fix][client] Fix logging problem in pulsar client (#21094)
This is an automated email from the ASF dual-hosted git repository.
technoboy pushed a commit to branch branch-2.11
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-2.11 by this push:
new b76118c75af [fix][client] Fix logging problem in pulsar client (#21094)
b76118c75af is described below
commit b76118c75afcb7a539588870acd2c326b5b6a097
Author: 萧易客 <km...@live.com>
AuthorDate: Thu Aug 31 16:18:17 2023 +0800
[fix][client] Fix logging problem in pulsar client (#21094)
---
.../src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java
index ac453281d0d..b4cbe9dbb72 100644
--- a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java
+++ b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java
@@ -417,7 +417,7 @@ public class ConsumerImpl<T> extends ConsumerBase<T> implements ConnectionHandle
unsubscribeFuture.completeExceptionally(
PulsarClientException.wrap(e.getCause(),
String.format("Failed to unsubscribe the subscription %s of topic %s",
- topicName.toString(), subscription)));
+ subscription, topicName.toString())));
return null;
});
} else {
@@ -2564,9 +2564,9 @@ public class ConsumerImpl<T> extends ConsumerBase<T> implements ConnectionHandle
return;
}
+ log.warn("[{}] [{}] Could not get connection while getLastMessageId -- Will try again in {} ms",
+ topic, getHandlerName(), nextDelay);
((ScheduledExecutorService) client.getScheduledExecutorProvider().getExecutor()).schedule(() -> {
- log.warn("[{}] [{}] Could not get connection while getLastMessageId -- Will try again in {} ms",
- topic, getHandlerName(), nextDelay);
remainingTime.addAndGet(-nextDelay);
internalGetLastMessageIdAsync(backoff, remainingTime, future);
}, nextDelay, TimeUnit.MILLISECONDS);